add

src/main/java/com/zfire/jiasm/syncdata/download/order/DetailDownloadInstallTask.java

@@ -113,7 +113,7 @@ public class DetailDownloadInstallTask {
 
 	// 从格力总部同步的采集附件图生成平台的采集图
 	@Scheduled(fixedDelayString = "${cjfile}")
-	public void processBX(){
+	public void processFJ(){
 		if (cjfilec.equals(TaskConfigEnum.FALSE.getCode())){
 			return;
 		}
@@ -127,6 +127,22 @@ public class DetailDownloadInstallTask {
 		log.info("生成商户到平台采集附件图信息结束: \uF0B7{}",sdf.format(new Date()));
 	}
 
+	// 从格力总部同步的商用条码图生成平台的条码图
+	@Scheduled(fixedDelayString = "${cjfile}")
+	public void processSY(){
+		if (cjfilec.equals(TaskConfigEnum.FALSE.getCode())){
+			return;
+		}
+
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+		log.info("开始生成商户(商用)到平台采集条码图信息: \uF0B7{}",sdf.format(new Date()));
+
+		glppwxgQueryAddService.extractedTMSYFile();
+
+		log.info("生成商户(商用)到平台采集条码图信息结束: \uF0B7{}",sdf.format(new Date()));
+	}
+
 
 
 

src/main/java/com/zfire/jiasm/syncdata/service/GLPPWXGQueryAddService.java

@@ -16,5 +16,6 @@ public interface GLPPWXGQueryAddService {
     void extractedBx();
 
     void extractedMXFile();
+    void extractedTMSYFile();
 
 }

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

@@ -1464,6 +1464,7 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 		a.setGreeImageId(item.getScwj());
 		a.setPgwcmxid(item.getPgwcmxid());
 		a.setTmguid(item.getTmguid());
+		a.setOutPicture(item.getScwj());
 		odfs.add(a);
 	}
 

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

@@ -90,6 +90,8 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
     InsureWorkerCommercialFileService insureWorkerCommercialFileService;
     @Resource
     OrderDetailFileService orderDetailFileService;
+    @Resource
+    OrderInstallDetailCodeService orderInstallDetailCodeService;
 
 
     @Override
@@ -491,6 +493,32 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
         updateMXFile(odfilesUpList, 0);
     }
 
+    @Override
+    public void extractedTMSYFile(){
+        List<OrderInstallDetailCode> odfiles = new ArrayList<>();
+        List<OrderInstallDetailCode> odfilesUpList = new ArrayList<>();
+
+        odfiles = orderInstallDetailCodeService.lambdaQuery()
+                .eq(OrderInstallDetailCode::getOutZjljProcess,0)
+                .isNotNull(OrderInstallDetailCode::getOutPicture).list();
+
+        for (OrderInstallDetailCode item :odfiles){
+            try{
+                // 生成图片
+                processSYTMFileInfo(item);
+                odfilesUpList.add(item);
+
+                updateSYTMFile(odfilesUpList, 10);
+            } catch (Exception ex) {
+                ex.printStackTrace();
+                updateSYTMFile(odfilesUpList, 0);
+                log.info("生成商户到平台采集条码图信息失败order_install_detail_code.id= {}",item.getId());
+            }
+        }
+
+        updateSYTMFile(odfilesUpList, 0);
+    }
+
 
     private void updateWorkerCertInfo(List<WorkerCert> workerCertUpList, int i) {
         if (workerCertUpList.size() > i) {
@@ -520,6 +548,13 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
         }
     }
 
+    private void updateSYTMFile(List<OrderInstallDetailCode> iwcfilesUpList, int i) {
+        if (iwcfilesUpList.size() > i) {
+            orderInstallDetailCodeService.updateBatchById(iwcfilesUpList);
+            iwcfilesUpList.clear();
+        }
+    }
+
     private void upWebsitWorker(List<WebsitWorker> websitWorkerUp) {
         if (websitWorkerUp.size()>0){
             websitWorkerService.saveOrUpdateBatch(websitWorkerUp);
@@ -1191,6 +1226,22 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
         }
     }
 
+    private void processSYTMFileInfo(OrderInstallDetailCode iwcfile) throws IOException {
+        if (StringUtils.isNotEmpty(iwcfile.getOutPicture())){
+            String id = putCert(iwcfile.getOutPicture());
+            if (StringUtils.isNotEmpty(id)){
+                iwcfile.setPath(id);
+                iwcfile.setGreeImageId(iwcfile.getOutPicture());
+                iwcfile.setOutZjljProcess(1);
+                iwcfile.setCreateTime(new Date());
+                new File(id).delete();
+            }
+
+        } else {
+            iwcfile.setOutZjljProcess(1);
+        }
+    }
+
     private void setAdd(WangdianWxgVos wvos, String workerId, String workerName, ZJInfo zj, WorkerCert add) throws ParseException {
         add.setId(publicService.getUUID());
         add.setWorkerId(workerId);