1111

src/main/java/com/fdkankan/contro/mq/nsq/NsqMesgDeal.java

@@ -78,7 +78,8 @@ public class NsqMesgDeal implements NSQMessageCallback {
             //通知平台文件已下载（删除文件）
             JSONObject param = new JSONObject();
             param.put("filename", data.getFilename());
-//            mjHttpClient.notify(param);
+            Result notify = mjHttpClient.notify(param);
+            log.info("distributeDetail-notify:{}", notify);
         }catch (Exception e){
             data.setReason(ExceptionUtil.stacktraceToString(e, 5000));
             data.setStatus(CommonSuccessStatus.FAIL.code());

src/main/java/com/fdkankan/contro/service/impl/MjServiceImpl.java

@@ -11,6 +11,7 @@ import com.fdkankan.common.constant.CommonSuccessStatus;
 import com.fdkankan.common.constant.RecStatus;
 import com.fdkankan.common.constant.SceneStatus;
 import com.fdkankan.common.util.SnowflakeIdGenerator;
+import com.fdkankan.contro.common.Result;
 import com.fdkankan.contro.entity.SceneFileBuild;
 import com.fdkankan.contro.entity.SceneFilename;
 import com.fdkankan.contro.entity.SceneOrigBd;
@@ -127,7 +128,8 @@ public class MjServiceImpl implements MjService {
         JSONObject param = new JSONObject();
         param.put("data", status);
         param.put("filename", filename);
-//        mjHttpClient.done(param);
+        Result done = mjHttpClient.done(param);
+        log.info("-------------distributeDetailDone:{}", done);
     }
 
     public static void main(String[] args) {