From a58208ba19f52c8d13a0ab1a88bd62ffe8802dd3 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 20 三月 2025 17:03:45 +0800
Subject: [PATCH] 最新版本541200007

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java |   42 ++++++++++++++++++++++++++++++------------
 1 files changed, 30 insertions(+), 12 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java
index b5f6916..5e7173a 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/WmsServiceImpl.java
@@ -73,6 +73,8 @@
     private RetentionMapper retentionMapper;
     @Autowired
     private WxNoticeConfigMapper wxNoticeConfigMapper;
+    @Autowired
+    private PlatformLogMapper platformLogMapper;
     /**
      * 鍏ュ簱閫氱煡浠诲姟涓氬姟澶勭悊
      * @param job 鍙傛暟
@@ -131,7 +133,7 @@
                 && response.getData().size()>0 && StringUtils.equals(response.getData().get(0).getSuccess(),WmsBaseResponse.CODE_SUCCESS)){
             //濡傛灉鎴愬姛
             update.setWmsSendStatus(Constants.ONE);
-            update.setWmsSendInfo("閫氱煡WMS浣滀笟鍗曞垎閰嶆湀鍙版垚鍔�");
+            update.setWmsSendInfo("閫氱煡WMS浣滀笟鍗曞垎閰嶆湀鍙版垚鍔�"+response.getData().get(0).getMsgDescr());
          }else{
             //濡傛灉澶辫触
             update.setWmsSendStatus(Constants.TWO);
@@ -266,6 +268,7 @@
                     job.setIsdeleted(Constants.ZERO);
                     job.setIsNew(Constants.ONE);
                     job.setStatus(Constants.ONE);
+                    job.setContractNum(param.getContractNum());
                     job.setCarryBillCode(param.getCarrierBillCode());
                     job.setIocode(param.getIoCode());
                     job.setCarrierName(param.getCarrierName());
@@ -279,7 +282,7 @@
                     platformWmsJobMapper.insert(job);
                     jobList.add(model);
                 }
-                jobIdList.add(job.getId());
+                jobIdList.add(job.getJobId());
                 if(param.getDetails()!=null && param.getDetails().size()>0){
                     for(WmsInboundDetailRequest d :param.getDetails()){
                         PlatformWmsDetail entity = new PlatformWmsDetail();
@@ -287,6 +290,7 @@
                         entity.setIsdeleted(Constants.ZERO);
                         entity.setIocode(d.getIoCode());
                         entity.setJobId(job.getJobId());
+                        entity.setContractNum(param.getContractNum());
                         entity.setWmsJobId(job.getId());
                         entity.setIoQty(d.getIoQty());
                         entity.setStatus(Constants.ZERO);
@@ -310,8 +314,8 @@
             if(details.size()>0){
                 platformWmsDetailMapper.insert(details);
             }
+            list.setJobIdList(jobIdList);
             if(jobList.size()>0){
-                list.setJobIdList(jobIdList);
                 startEndNoticeToDriver(jobList);
             }
         }catch (Exception e){
@@ -429,6 +433,22 @@
             job.setCompanyNamePath(driver.getCompanyNamePath());
         }
         platformJobMapper.insert(job);
+        if(car !=null){
+            //瀛樺偍鎿嶄綔鏃ュ織
+            PlatformLog platformLog = new PlatformLog();
+            platformLog.setIsdeleted(Constants.ZERO);
+            platformLog.setCreateDate(new Date());
+            platformLog.setJobId(job.getId());
+            platformLog.setObjType(Constants.PlatformJobLogType.SIGN.getKey());
+            platformLog.setContent("鑷姩绛惧埌");
+            platformLog.setParam4(job.getCarCodeFront());
+            platformLog.setAfterContent(JSONObject.toJSONString(job));
+            platformLog.setObjId(job.getId().toString());
+            platformLog.setParam3("0");
+            platformLogMapper.insert(platformLog);
+        }
+
+
     }
 
     private PlatformJob dealJobBizOutbound(WmsOutboundNoticeRequest param) {
@@ -495,10 +515,9 @@
                     job.setContractNum(param.getContractNum());
                     job.setDriverPhone(param.getDriverPhone());
                     job.setDriverName(param.getDriverName());
-//                    job.setOrigin(Constants.ONE);
                     platformWmsJobMapper.insert(job);
                 }
-                jobIdList.add(job.getId());
+                jobIdList.add(job.getJobId());
                 if(param.getDetails()!=null && param.getDetails().size()>0){
                     for(WmsOutboundDetailRequest d :param.getDetails()){
                         PlatformWmsDetail entity = new PlatformWmsDetail();
@@ -532,8 +551,8 @@
             if(details.size()>0){
                 platformWmsDetailMapper.insert(details);
             }
+            list.setJobIdList(jobIdList);
             if(jobList.size()>0){
-                list.setJobIdList(jobIdList);
                 startEndNoticeToDriver(jobList);
             }
         }catch (Exception e){
@@ -723,14 +742,13 @@
                     .eq(PlatformWmsDetail::getIsdeleted, Constants.ZERO));
             if(details!=null && details.size()>0){
                 for(PlatformWmsDetail d :details){
-                   num.add(Constants.formatBigdecimal(d.getIoQty()));
+                    num =  num.add(Constants.formatBigdecimal(d.getIoQty()));
                 }
-                platformJobMapper.update(null,new UpdateWrapper<PlatformJob>().lambda()
-                        .set(PlatformJob::getTotalNum,num)
-                        .eq(PlatformJob::getOrigin, Constants.ZERO)
-                        .eq(PlatformJob::getId, jobId));
             }
-
+            platformJobMapper.update(null,new UpdateWrapper<PlatformJob>().lambda()
+                    .set(PlatformJob::getTotalNum,num)
+                    .eq(PlatformJob::getOrigin, Constants.ONE)
+                    .eq(PlatformJob::getId, jobId));
         }
     }
     /**

--
Gitblit v1.9.3