add

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

@@ -8,6 +8,7 @@ import com.zfire.jiasm.syncdata.data.DetailDownloadData;
 import com.zfire.jiasm.syncdata.data.Token;
 import com.zfire.jiasm.syncdata.plus.entity.SysDict;
 import com.zfire.jiasm.syncdata.service.DetailDownloadService;
+import com.zfire.jiasm.syncdata.service.GLPPWXGQueryAddService;
 import com.zfire.jiasm.syncdata.service.PublicService;
 import com.zfire.jiasm.syncdata.utils.DataUtil;
 import com.zfire.jiasm.syncdata.utils.HttpUtil;
@@ -20,6 +21,7 @@ import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 
@@ -33,6 +35,10 @@ public class DetailDownloadInstallTask {
 	private String baseurl = "";
 	@Value("${detaildownc}")
 	private String detaildownc = "";
+	@Value("${cjfilec}")
+	private String cjfilec = "";
+
+
 
 	@Autowired
 	private TokenCenter tokenCenter;
@@ -40,6 +46,8 @@ public class DetailDownloadInstallTask {
 	private DetailDownloadService detailDownloadService;
 	@Resource
 	PublicService publicService;
+	@Resource
+	GLPPWXGQueryAddService glppwxgQueryAddService;
 
 
 	@Scheduled(fixedDelayString = "${detaildown}")
@@ -90,6 +98,40 @@ public class DetailDownloadInstallTask {
 		}
 	}
 
+	// 从格力总部同步的采集附件图生成平台的采集图
+	@Scheduled(fixedDelayString = "${cjfile}")
+	public void processBX(){
+		if (cjfilec.equals(TaskConfigEnum.TRUE.getCode())){
+			return;
+		}
+
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+		log.info("开始生成网点师傅保险证件信息: \uF0B7{}",sdf.format(new Date()));
+
+		glppwxgQueryAddService.extractedMXFile();
+
+		log.info("生成网点师傅保险证件信息结束: \uF0B7{}",sdf.format(new Date()));
+	}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
 	private void getDatas(Token token, String downloadTaskNo, String downloadKeyValue, List<Map<String, Object>> tables, List<DetailDownloadData> detailDownloadDatas) throws Exception {
 		for (Map<String, Object> table : tables) {
 			String downloadMode = (String) table.get("download_mode");

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

@@ -13,4 +13,6 @@ public interface GLPPWXGQueryAddService {
     void extractedCert();
     void extractedBx();
 
+    void extractedMXFile();
+
 }

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

@@ -382,7 +382,6 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 
 		// 提取采集数据
 		oids = orderInstallDetailService.lambdaQuery()
-				.select(OrderInstallDetail::getPgwcmxid,OrderInstallDetail::getId)
 				.eq(OrderInstallDetail::getPgwcmxid,pgguid).list();
 		oidsMap = oids.stream().collect(Collectors.groupingBy(OrderInstallDetail::getPgwcmxid));
 
@@ -1148,6 +1147,7 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 		a.setFjguid(item.getFjguid());
 		a.setOrderBaseId(order.getId());
 		a.setOrderDetailId(oid.getId());
+		// setFileName
 		setType(item.getType(),item.getFjname(), a);
 		// 附件地址
 		// a.setFilePath();
@@ -1163,6 +1163,7 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 		a.setCreateBy(item.getCreatedBy());
 		a.setUpdateTime(item.getLastModifiedDate());
 		a.setUpdateBy(item.getLastModifiedBy());
+		a.setOutPicture(item.getFjserverpath());
 		odfs.add(a);
 	}
 

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

@@ -87,6 +87,8 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
     InsureWorkerCommercialService insureWorkerCommercialService;
     @Resource
     InsureWorkerCommercialFileService insureWorkerCommercialFileService;
+    @Resource
+    OrderDetailFileService orderDetailFileService;
 
 
 
@@ -287,6 +289,33 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
         updateBxInfo(iwcfilesUpList, 0);
     }
 
+    @Override
+    public void extractedMXFile(){
+        List<OrderDetailFile> odfiles = new ArrayList<>();
+        List<OrderDetailFile> odfilesUpList = new ArrayList<>();
+
+        odfiles = orderDetailFileService.lambdaQuery()
+                .eq(OrderDetailFile::getOutZjljProcess,0)
+                .isNotNull(OrderDetailFile::getOutPicture).list();
+
+        for (OrderDetailFile item :odfiles){
+            try{
+                // 生成图片
+                processMXFileInfo(item);
+                odfilesUpList.add(item);
+
+                updateMXFile(odfilesUpList, 100);
+            } catch (Exception ex) {
+                ex.printStackTrace();
+                updateMXFile(odfilesUpList, 0);
+                log.info("生成采集附件照信息失败order_detail_file.id= {}",item.getId());
+            }
+        }
+
+        updateMXFile(odfilesUpList, 0);
+    }
+
+
     private void updateWorkerCertInfo(List<WorkerCert> workerCertUpList, int i) {
         if (workerCertUpList.size() > i) {
             workerCertService.updateBatchById(workerCertUpList);
@@ -301,6 +330,13 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
         }
     }
 
+    private void updateMXFile(List<OrderDetailFile> iwcfilesUpList, int i) {
+        if (iwcfilesUpList.size() > i) {
+            orderDetailFileService.updateBatchById(iwcfilesUpList);
+            iwcfilesUpList.clear();
+        }
+    }
+
     private void upWebsitWorker(List<WebsitWorker> websitWorkerUp) {
         if (websitWorkerUp.size()>0){
             websitWorkerService.saveOrUpdateBatch(websitWorkerUp);
@@ -897,6 +933,20 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
         }
     }
 
+    private void processMXFileInfo(OrderDetailFile iwcfile) throws IOException {
+        if (StringUtils.isNotEmpty(iwcfile.getOutPicture())){
+            String id = putCert(iwcfile.getOutPicture());
+            if (StringUtils.isNotEmpty(id)){
+                iwcfile.setFilePath(id);
+                iwcfile.setBrandFilePath(iwcfile.getOutPicture());
+                iwcfile.setOutZjljProcess(1);
+                iwcfile.setCreateTime(new Date());
+                new File(id).delete();
+            }
+
+        }
+    }
+
     private void setAdd(WangdianWxgVos wvos, String workerId, String workerName, ZJInfo zj, WorkerCert add) throws ParseException {
         add.setId(UUID.randomUUID().toString());
         add.setWorkerId(workerId);

src/main/resources/bootstrap-dev.properties

@@ -250,7 +250,7 @@ ththhgx=60000
 #维修转结算、维修转结算查询最终结果
 wxzjs=60000
 wxzjscx=60000
-#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险
+#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险、总部下载的采集图
 zjzxx=600000
 lmxx=60000
 wxgwz=60000
@@ -258,6 +258,7 @@ wxgxg=60000
 wxgwzt=60000
 wdwxgt=600000
 zjzbx=600000
+cjfile=60000
 #京东商城 预约改约、指派改派网点、作废取消、报完工、指派改派人员
 jdyygy=30000
 jdzpgpwd=30000
@@ -364,13 +365,14 @@ ththhgxc=FALSE
 #维修转结算、维修转结算查询最终结果
 wxzjsc=FALSE
 wxzjscxc=FALSE
-#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险
+#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险、总部下载的采集图
 zjzxxc=FALSE
 lmxxc=FALSE
 wxgwzc=FALSE
 wxgxgc=FALSE
 wxgwztc=FALSE
 zjzbxc=FALSE
+cjfilec=FALSE
 #京东商城 预约改约、指派改派网点、作废取消、报完工、指派改派人员
 jdyygyc=FALSE
 jdzpgpwdc=FALSE

src/main/resources/bootstrap-prd.properties

@@ -247,7 +247,7 @@ ththhgx=60000
 #维修转结算、维修转结算查询最终结果
 wxzjs=60000
 wxzjscx=60000
-#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险
+#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险、总部下载的采集图
 zjzxx=600000
 lmxx=600000
 wxgwz=600000
@@ -255,6 +255,7 @@ wxgxg=600000
 wxgwzt=600000
 wdwxgt=600000
 zjzbx=60000
+cjfile=60000
 #京东商城 预约改约、指派改派网点、作废取消、报完工、指派改派人员
 jdyygy=30000
 jdzpgpwd=30000
@@ -362,13 +363,14 @@ ththhgxc=TRUE
 #维修转结算、维修转结算查询最终结果
 wxzjsc=TRUE
 wxzjscxc=TRUE
-#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险
+#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险、总部下载的采集图
 zjzxxc=TRUE
 lmxxc=TRUE
 wxgwzc=FALSE
 wxgxgc=TRUE
 wxgwztc=FALSE
 zjzbxc=TRUE
+cjfilec=TRUE
 #京东商城 预约改约、指派改派网点、作废取消、报完工、指派改派人员
 jdyygyc=TRUE
 jdzpgpwdc=TRUE

src/main/resources/bootstrap-test.properties

@@ -251,7 +251,7 @@ ththhgx=7200000
 #维修转结算、维修转结算查询最终结果
 wxzjs=7200000
 wxzjscx=7200000
-#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险
+#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险、总部下载的采集图
 zjzxx=600000
 lmxx=600000
 wxgwz=600000
@@ -259,6 +259,7 @@ wxgxg=60000
 wxgwzt=600000
 wdwxgt=600000
 zjzbx=600000
+cjfile=60000
 #京东商城 预约改约、指派改派网点、作废取消、报完工、指派改派人员
 jdyygy=30000
 jdzpgpwd=30000
@@ -365,13 +366,14 @@ ththhgxc=FALSE
 #维修转结算、维修转结算查询最终结果
 wxzjsc=FALSE
 wxzjscxc=FALSE
-#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险
+#网点维修工 证件照，服务类目，位置、新增同步到本地、修改、保险、总部下载的采集图
 zjzxxc=TRUE
 lmxxc=TRUE
 wxgwzc=TRUE
 wxgxgc=TRUE
 wxgwztc=TRUE
 zjzbxc=TRUE
+cjfilec=TRUE
 #京东商城 预约改约、指派改派网点、作废取消、报完工、指派改派人员
 jdyygyc=TRUE
 jdzpgpwdc=TRUE