bug修改

src/main/java/com/glxp/api/controller/trace/TraceManuOrderController.java

@@ -16,10 +16,9 @@ import com.glxp.api.req.trace.*;
 import com.glxp.api.res.PageSimpleResponse;
 import com.glxp.api.res.trace.TraceManuCodeRellResponse;
 import com.glxp.api.res.trace.TraceManuOrderResponse;
-import com.glxp.api.service.trace.TraceManuCodeRelService;
 import com.glxp.api.service.trace.TraceManuOrderService;
 import com.glxp.api.service.trace.TraceTaskNoticeService;
-import com.glxp.api.service.trace.TraceTaskService;
+import com.glxp.api.service.trace.impl.TraceManuCodeRelService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
@@ -114,16 +113,24 @@ public class TraceManuOrderController {
             return ResultVOUtils.error(500, "UDI码关联关系不能为空！");
         }
         List<TraceManuCodeRelEntity> traceManuCodeRelEntities = new ArrayList<>();
+        try {
+            traceManuOrderService.replace(traceManuOrderEntity);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
         traceManuDetailRequests.stream().forEach(item -> {
             TraceManuCodeRelEntity traceManuCodeRelEntity = new TraceManuCodeRelEntity();
             BeanUtils.copyProperties(item, traceManuCodeRelEntity);
             traceManuCodeRelEntity.setManuOrderIdFk(traceManuOrderEntity.getId());
-            traceManuCodeRelEntity.setManuOrderNo(traceManuOrderEntity.getRecordCode());
+            traceManuCodeRelEntity.setManuOrderNo(traceManuOrderEntity.getBillNo());
             traceManuCodeRelEntity.setId(IdUtil.getSnowflakeNextId());
             traceManuCodeRelEntities.add(traceManuCodeRelEntity);
         });
-        traceManuOrderService.save(traceManuOrderEntity);
+
-        traceManuCodeRelService.saveOrUpdateBatch(traceManuCodeRelEntities);
+        traceManuCodeRelService.replaceList(traceManuCodeRelEntities);
+        taskNoticeEntity.setStatus(3);
+        taskNoticeEntity.setUpdateTime(new Date());
+        traceTaskNoticeService.updateById(taskNoticeEntity);
         return ResultVOUtils.success("成功");
     }
 

src/main/java/com/glxp/api/controller/trace/TraceOrderController.java

@@ -93,7 +93,10 @@ public class TraceOrderController extends BaseController {
         traceOrderEntity.setTraceProductIdFk(taskNoticeEntity.getProdudctRecordIdFk());
         traceOrderEntity.setId(IdUtil.getSnowflakeNextId());
         traceOrderEntity.setUpdateTime(new Date());
-        traceOrderService.save(traceOrderEntity);
+        traceOrderService.replace(traceOrderEntity);
+        taskNoticeEntity.setStatus(3);
+        taskNoticeEntity.setUpdateTime(new Date());
+        traceTaskNoticeService.updateById(taskNoticeEntity);
         System.out.println("成功");
         return ResultVOUtils.success("成功");
     }

src/main/java/com/glxp/api/controller/trace/UdiTraceController.java

@@ -26,6 +26,7 @@ import com.glxp.api.service.basic.BasicUdiRelService;
 import com.glxp.api.service.sup.UserCompanyService;
 import com.glxp.api.service.system.SystemParamConfigService;
 import com.glxp.api.service.trace.*;
+import com.glxp.api.service.trace.impl.TraceManuCodeRelService;
 import com.glxp.api.util.GennerOrderUtils;
 import com.glxp.api.util.udi.FilterUdiUtils;
 import io.swagger.annotations.Api;

src/main/java/com/glxp/api/dao/trace/TraceManuCodeRelMapper.java

@@ -1,7 +1,9 @@
 package com.glxp.api.dao.trace;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.glxp.api.dao.BaseMapperPlus;
 import com.glxp.api.entity.trace.TraceManuCodeRelEntity;
+import com.glxp.api.entity.trace.TraceOrderEntity;
 import com.glxp.api.req.trace.TraceManuDetailRequest;
 import com.glxp.api.req.trace.TraceManuOrderRequest;
 import com.glxp.api.res.trace.TraceManuCodeRellResponse;
@@ -11,7 +13,6 @@ import org.apache.ibatis.annotations.Mapper;
 import java.util.List;
 
 @Mapper
-public interface TraceManuCodeRelMapper extends BaseMapper<TraceManuCodeRelEntity> {
+public interface TraceManuCodeRelMapper extends BaseMapperPlus<TraceManuCodeRelMapper, TraceManuCodeRelEntity, TraceManuCodeRelEntity> {
-
     List<TraceManuCodeRellResponse> filterTraceManuCodeRel(TraceManuDetailRequest traceManuDetailRequest);
 }

src/main/java/com/glxp/api/dao/trace/TraceManuOrderMapper.java

@@ -1,6 +1,7 @@
 package com.glxp.api.dao.trace;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.glxp.api.dao.BaseMapperPlus;
 import com.glxp.api.entity.trace.TraceManuOrderEntity;
 import com.glxp.api.req.trace.TraceManuOrderRequest;
 import com.glxp.api.res.trace.TraceManuOrderResponse;
@@ -9,7 +10,7 @@ import org.apache.ibatis.annotations.Mapper;
 import java.util.List;
 
 @Mapper
-public interface TraceManuOrderMapper extends BaseMapper<TraceManuOrderEntity> {
+public interface TraceManuOrderMapper extends BaseMapperPlus<TraceManuOrderMapper, TraceManuOrderEntity, TraceManuOrderEntity> {
 
     List<TraceManuOrderResponse> filterTraces(TraceManuOrderRequest traceManuOrderRequest);
 

src/main/java/com/glxp/api/dao/trace/TraceOrderMapper.java

@@ -1,7 +1,10 @@
 package com.glxp.api.dao.trace;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.glxp.api.dao.BaseMapperPlus;
+import com.glxp.api.dao.system.SystemPDFModuleDao;
 import com.glxp.api.entity.sup.UserCompanyEntity;
+import com.glxp.api.entity.system.SystemPDFModuleEntity;
 import com.glxp.api.entity.trace.TraceOrderEntity;
 import com.glxp.api.req.auth.FilterUserComapanyRequest;
 import com.glxp.api.req.trace.TraceOrderDetailRequest;
@@ -14,7 +17,7 @@ import org.apache.ibatis.annotations.Mapper;
 import java.util.List;
 
 @Mapper
-public interface TraceOrderMapper extends BaseMapper<TraceOrderEntity> {
+public interface TraceOrderMapper extends BaseMapperPlus<TraceOrderMapper, TraceOrderEntity, TraceOrderEntity> {
 
     List<TraceOrderResponse> queryTraceOrderList(TraceOrderDetailRequest traceOrderDetailRequest);
 

src/main/java/com/glxp/api/service/trace/TraceManuCodeRelService.java

@@ -1,13 +0,0 @@
-package com.glxp.api.service.trace;
-
-import com.glxp.api.entity.trace.TraceManuCodeRelEntity;
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.glxp.api.req.trace.TraceManuDetailRequest;
-import com.glxp.api.res.trace.TraceManuCodeRellResponse;
-
-import java.util.List;
-
-public interface TraceManuCodeRelService extends IService<TraceManuCodeRelEntity> {
-
-    List<TraceManuCodeRellResponse> filterList(TraceManuDetailRequest traceManuDetailRequest);
-}

src/main/java/com/glxp/api/service/trace/TraceManuOrderService.java

@@ -42,4 +42,8 @@ public class TraceManuOrderService extends ServiceImpl<TraceManuOrderMapper, Tra
         return traceManuOrderEntity;
 
     }
+
+    public boolean replace(TraceManuOrderEntity traceManuOrderEntity) {
+        return traceManuOrderMapper.replace(traceManuOrderEntity) > 0;
+    }
 }

src/main/java/com/glxp/api/service/trace/TraceOrderService.java

@@ -83,5 +83,8 @@ public class TraceOrderService extends ServiceImpl<TraceOrderMapper, TraceOrderE
         return traceOrderMapper.filterJoin(traceOrderDetailRequest);
     }
 
+    public boolean replace(TraceOrderEntity traceOrderEntity) {
+        return traceOrderMapper.replace(traceOrderEntity) > 0;
+    }
 
 }

src/main/java/com/glxp/api/service/trace/UdiTraceService.java

@@ -132,10 +132,10 @@ public class UdiTraceService {
         if (manuTaskNotity == null) {
             manuTaskNotity = createTraceNotice(1, traceProductDetailEntity, companyId);
             pushDelayExpireTask(manuTaskNotity);
-            pushMq(traceProductDetailEntity, companyId);
+            pushMq(manuTaskNotity, companyId);
         } else if (manuTaskNotity.getStatus() == 4) {
             //任务超时未处理，重新推送消息
-            pushMq(traceProductDetailEntity, companyId);
+            pushMq(manuTaskNotity, companyId);
         }
 
         //2.出入库生产订单关联关系
@@ -143,10 +143,10 @@ public class UdiTraceService {
         if (inoutTaskNotity == null) {
             inoutTaskNotity = createTraceNotice(2, traceProductDetailEntity, companyId);
             pushDelayExpireTask(inoutTaskNotity);
-            pushMq(traceProductDetailEntity, companyId);
+            pushMq(inoutTaskNotity, companyId);
         } else if (inoutTaskNotity.getStatus() == 4) {
             //任务超时未处理，重新推送消息
-            pushMq(traceProductDetailEntity, companyId);
+            pushMq(inoutTaskNotity, companyId);
         }
 
 
@@ -166,10 +166,10 @@ public class UdiTraceService {
                 if (taskNoticeEntity == null) {
                     taskNoticeEntity = createTraceNotice(1, traceProductDetailEntity, companyId);
                     pushDelayExpireTask(taskNoticeEntity);
-                    pushMq(traceProductDetailEntity, companyId);
+                    pushMq(taskNoticeEntity, companyId);
                 } else if (taskNoticeEntity.getStatus() == 4) {
                     //任务超时未处理，重新推送消息
-                    pushMq(traceProductDetailEntity, companyId);
+                    pushMq(taskNoticeEntity, companyId);
                 }
             }
         }
@@ -178,11 +178,18 @@ public class UdiTraceService {
     //    创建现场检查询任务
     public void createCheckTraceTask(TraceProductDetailEntity traceProductDetailEntity, Long companyId) {
 
-        //1.查询出入库单消息是否已经上传
+
-        if (traceProductDetailEntity.getStatus() == 1) {        //出入库订单未处理
+        TraceTaskNoticeEntity inoutTaskNotity = traceTaskNoticeService.findTask(2, traceProductDetailEntity.getId(), companyId);
-            createTraceNotice(2, traceProductDetailEntity, companyId);
+        if (inoutTaskNotity == null) {
-            pushMq(traceProductDetailEntity, companyId);
+            inoutTaskNotity = createTraceNotice(2, traceProductDetailEntity, companyId);
-        } else if (traceProductDetailEntity.getStatus() == 2) { //出入库订单未处理完成
+            pushDelayExpireTask(inoutTaskNotity);
+            pushMq(inoutTaskNotity, companyId);
+        } else if (inoutTaskNotity.getStatus() == 4) {
+            //任务超时未处理，重新推送消息
+            pushMq(inoutTaskNotity, companyId);
+        }
+
+        if (traceProductDetailEntity.getStatus() == 2) { //出入库订单未处理完成
             //列出需要查询推送企业
             List<TraceOrderEntity> traceOrderEntities = traceOrderService.findByProductIdFk(traceProductDetailEntity.getId());
             if (CollUtil.isNotEmpty(traceOrderEntities)) {
@@ -202,10 +209,10 @@ public class UdiTraceService {
                     if (taskNoticeEntity == null) {
                         taskNoticeEntity = createTraceNotice(1, traceProductDetailEntity, companyId);
                         pushDelayExpireTask(taskNoticeEntity);
-                        pushMq(traceProductDetailEntity, companyId);
+                        pushMq(taskNoticeEntity, companyId);
                     } else if (taskNoticeEntity.getStatus() == 4) {
                         //任务超时未处理，重新推送消息
-                        pushMq(traceProductDetailEntity, companyId);
+                        pushMq(taskNoticeEntity, companyId);
                     }
                 }
             }
@@ -243,16 +250,16 @@ public class UdiTraceService {
     }
 
 
-    public void pushMq(TraceProductDetailEntity traceProductDetailEntity, Long companyId) {
+    public void pushMq(TraceTaskNoticeEntity traceTaskNoticeEntity, Long companyId) {
         //6.构建MQ推送消息
         MqTraceMessage mqTraceMessage = new MqTraceMessage();
         mqTraceMessage.setCreateTime(new Date());
-        mqTraceMessage.setTaskType(1);
+        mqTraceMessage.setTaskType(traceTaskNoticeEntity.getTaskType());
         mqTraceMessage.setCompanyId(companyId);
-        mqTraceMessage.setCerditNo(traceProductDetailEntity.getCreditNum());
+        mqTraceMessage.setCerditNo(traceTaskNoticeEntity.getCreditNum());
-        mqTraceMessage.setTaskId(traceProductDetailEntity.getId());
+        mqTraceMessage.setTaskId(traceTaskNoticeEntity.getId());
-        rabbitPushService.send(mqTraceMessage);
+//        rabbitPushService.send(mqTraceMessage);
-//        rabbitPushService.publicPush(mqTraceMessage);
+        rabbitPushService.publicPush(mqTraceMessage);
     }
 
 

src/main/java/com/glxp/api/service/trace/impl/TraceManuCodeRelService.java

@@ -3,7 +3,6 @@ package com.glxp.api.service.trace.impl;
 import com.github.pagehelper.PageHelper;
 import com.glxp.api.req.trace.TraceManuDetailRequest;
 import com.glxp.api.res.trace.TraceManuCodeRellResponse;
-import com.glxp.api.service.trace.TraceManuCodeRelService;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.glxp.api.entity.trace.TraceManuCodeRelEntity;
@@ -14,12 +13,10 @@ import java.util.Collections;
 import java.util.List;
 
 @Service
-public class TraceManuCodeRelServiceImpl extends ServiceImpl<TraceManuCodeRelMapper, TraceManuCodeRelEntity> implements TraceManuCodeRelService {
+public class TraceManuCodeRelService extends ServiceImpl<TraceManuCodeRelMapper, TraceManuCodeRelEntity> {
-
     @Resource
     TraceManuCodeRelMapper traceManuCodeRelMapper;
 
-    @Override
     public List<TraceManuCodeRellResponse> filterList(TraceManuDetailRequest traceManuDetailRequest) {
         if (traceManuDetailRequest == null) {
             return Collections.emptyList();
@@ -30,4 +27,13 @@ public class TraceManuCodeRelServiceImpl extends ServiceImpl<TraceManuCodeRelMap
         }
         return traceManuCodeRelMapper.filterTraceManuCodeRel(traceManuDetailRequest);
     }
+
+
+    public boolean replace(TraceManuCodeRelEntity traceManuCodeRelEntity) {
+        return traceManuCodeRelMapper.replace(traceManuCodeRelEntity) > 0;
+    }
+
+    public boolean replaceList(List<TraceManuCodeRelEntity> traceManuCodeRelEntities) {
+        return traceManuCodeRelMapper.replaceBatch(traceManuCodeRelEntities) > 0;
+    }
 }

src/main/resources/application-dev.yml

@@ -4,9 +4,9 @@ server:
 spring:
   datasource:
     driver-class-name: com.p6spy.engine.spy.P6SpyDriver
-    jdbc-url: jdbc:p6spy:mysql://192.168.0.66:3364/udi_cpt?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
+    jdbc-url: jdbc:p6spy:mysql://127.0.0.1:3306/udi_cpt?allowMultiQueries=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowPublicKeyRetrieval=true
     username: root
-    password: Glxp@6066
+    password: 123456
     hikari:
       connection-timeout: 60000
       maximum-pool-size: 20
@@ -15,7 +15,7 @@ spring:
 
   redis:
     database: 14
-    host: 192.168.0.166
+    host: 127.0.0.1
     port: 6379
     #    password: 123456
     timeout: 300
@@ -34,7 +34,7 @@ spring:
       max-request-size: 500MB
 
   rabbitmq:
-    host: 192.168.0.166
+    host: 127.0.0.1
     port: 5672
     username: cpt
     password: 123456