From ad2ae2290ee00120758008a7df31e6639e0b518b Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期二, 29 十月 2024 22:45:38 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

---
 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java |   36 +++++++++++++++++++++++++++++++++---
 1 files changed, 33 insertions(+), 3 deletions(-)

diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java
index db9713f..7cc909c 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java
@@ -11,9 +11,11 @@
 import com.dy.pipIrrGlobal.command.enums.LastOperateENUM;
 import com.dy.pipIrrGlobal.command.result.CommandResultCode;
 import com.dy.pipIrrGlobal.daoBa.BaSettingsMapper;
+import com.dy.pipIrrGlobal.daoPr.PrCommonIntakesMapper;
 import com.dy.pipIrrGlobal.daoPr.PrControllerMapper;
 import com.dy.pipIrrGlobal.daoRm.RmCommandHistoryMapper;
 import com.dy.pipIrrGlobal.daoSe.SeVirtualCardMapper;
+import com.dy.pipIrrGlobal.pojoPr.PrCommonIntakes;
 import com.dy.pipIrrGlobal.pojoPr.PrController;
 import com.dy.pipIrrGlobal.pojoRm.RmCommandHistory;
 import com.dy.pipIrrGlobal.pojoSe.SeVirtualCard;
@@ -78,6 +80,9 @@
 
     @Autowired
     private SeVirtualCardMapper seVirtualCardMapper;
+
+    @Autowired
+    private PrCommonIntakesMapper prCommonIntakesMapper;
 
     public static ComSupport comSupport;
 
@@ -279,6 +284,9 @@
         rmCommandHistoryMapper.insert(rmCommandHistory);
         comId = rmCommandHistory.getComId();
 
+        // 娣诲姞甯哥敤鍙栨按鍙f垨鏇存柊浣跨敤淇℃伅
+        addCommonIntake(operator, intakeId);
+
         /**
          * 澶勭悊鍥炶皟
          * feature鍑嗗灏辩华鍚庡彂閫佸懡浠�
@@ -345,9 +353,10 @@
                 job_data.remove("success");
                 job_data.put("intakeId", intakeId);
                 job_data.put("rtuAddr", rtuAddr);
-                job_data.put("vcNum", job_param.getString("icCardNo"));
-                job_data.put("orderNo", job_param.getString("orderNo"));
-
+                if(job_param != null) {
+                    job_data.put("vcNum", job_param.getString("icCardNo"));
+                    job_data.put("orderNo", job_param.getString("orderNo"));
+                }
                 response_CallBack = JSON.parseObject(job_response.toJSONString(), BaseResponse.class);
             }
         }
@@ -356,4 +365,25 @@
         return response_CallBack;
 
     }
+
+    /**
+     * 娣诲姞甯哥敤鍙栨按鍙f垨鏇存柊浣跨敤淇℃伅
+     * @param intakeId
+     * @return
+     */
+    public Integer addCommonIntake(Long operatorId, Long intakeId) {
+        PrCommonIntakes commonIntake = prCommonIntakesMapper.selectByOperatorAndIntake(operatorId, intakeId);
+        if(commonIntake == null) {
+            commonIntake = new PrCommonIntakes();
+            commonIntake.setOperatorId(operatorId);
+            commonIntake.setIntakeId(intakeId);
+            commonIntake.setLastUsedTime(new Date());
+            commonIntake.setUsageCount(1);
+            return prCommonIntakesMapper.insert(commonIntake);
+        }
+
+        commonIntake.setLastUsedTime(new Date());
+        commonIntake.setUsageCount(commonIntake.getUsageCount() + 1);
+        return prCommonIntakesMapper.updateByPrimaryKeySelective(commonIntake);
+    }
 }

--
Gitblit v1.8.0