add

src/main/java/com/zfire/jiasm/syncdata/service/impl/AddInstallBusinessImpl.java

@@ -507,49 +507,22 @@ public class AddInstallBusinessImpl implements AddInstallBusiness {
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public void getOrderAppraiseSelf() {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 
         // 提取需要处理的数据
         List<ItfReceiveSms> irsms = itfReceiveSmsService.lambdaQuery()
-                .eq(ItfReceiveSms::getSynStatus,0)
-                // .eq(ItfReceiveSms::getSynReqId,473L)// 测试用
+                // .eq(ItfReceiveSms::getSynStatus,0)
+                .eq(ItfReceiveSms::getSynReqId,473L)// 测试用
                 .orderByAsc(ItfReceiveSms::getSynReqId)
                 .list();
 
         for (ItfReceiveSms item:irsms){
             try {
-                // 提取工单信息 部分工单可能不在平台系统中，不在的不处理
-                // 同步工单回复信息 这里使用手机号+发送码来确认 存在无对应的情况不处理
-                // 最近两个月的一定只有一条，为防止出现问题，用list
-                SmsRecord smsRecord = smsRecordService.lambdaQuery()
-                        .eq(SmsRecord::getPhone, item.getFromNum())
-                        .eq(SmsRecord::getFsma, item.getSubappend())
-                        .ge(SmsRecord::getCreateTime,publicService.stepMonth(new Date(),-2))
-                        .last("limit 1").one();
-
-                // 无工单数据不处理
-                if (smsRecord == null){
-                    setItfReceiveSmsstatus(item,9,"找不到对应的工单不处理");
-                    continue;
-                }
-                // 提取工单数据 只处理自建工单
-                OrderBase orderBase = orderBaseService.lambdaQuery()
-                        .eq(OrderBase::getId,smsRecord.getOrderBaseId())
-                        .eq(OrderBase::getUploadFlag,Boolean.FALSE).one();
-                if (orderBase == null){
-                    setItfReceiveSmsstatus(item,9,"【"+smsRecord.getOrderBaseId()+"】非自建工单不处理");
+                if (processInfo(item)) {
                     continue;
                 }
 
-                // 按记录处理
-                if (processOrderAppraise(item, orderBase)) {
-                    continue;
-                }
-
-                setItfReceiveSmsstatus(item,1,"成功");
-
             }  catch (Exception ex) {
                 ex.printStackTrace();
                 item.setSynTime(new Date());
@@ -571,6 +544,39 @@ public class AddInstallBusinessImpl implements AddInstallBusiness {
         irsms.clear();
     }
 
+    @Transactional(rollbackFor = Exception.class)
+    public boolean processInfo(ItfReceiveSms item) {
+        // 提取工单信息 部分工单可能不在平台系统中，不在的不处理
+        // 同步工单回复信息 这里使用手机号+发送码来确认 存在无对应的情况不处理
+        // 最近两个月的一定只有一条，为防止出现问题，用list
+        SmsRecord smsRecord = smsRecordService.lambdaQuery()
+                .eq(SmsRecord::getPhone, item.getFromNum())
+                .eq(SmsRecord::getFsma, item.getSubappend())
+                .ge(SmsRecord::getCreateTime,publicService.stepMonth(new Date(),-2))
+                .last("limit 1").one();
+
+        // 无工单数据不处理
+        if (smsRecord == null){
+            setItfReceiveSmsstatus(item,9,"找不到对应的工单不处理");
+            return true;
+        }
+        // 提取工单数据 只处理自建工单
+        OrderBase orderBase = orderBaseService.lambdaQuery()
+                .eq(OrderBase::getId,smsRecord.getOrderBaseId())
+                .eq(OrderBase::getUploadFlag,Boolean.FALSE).one();
+        if (orderBase == null){
+            setItfReceiveSmsstatus(item,9,"【"+smsRecord.getOrderBaseId()+"】非自建工单不处理");
+            return true;
+        }
+
+        // 按记录处理
+        if (processOrderAppraise(item, orderBase)) {
+            return true;
+        }
+        setItfReceiveSmsstatus(item,1,"成功");
+        return false;
+    }
+
     public boolean processOrderAppraise(ItfReceiveSms item, OrderBase orderBase) {
         int cpflag=0;
         WebsitFWS websitFWS = new WebsitFWS();