Merge branch 'develop'

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

@@ -76,7 +76,7 @@ public class InstallBusinessApi {
         // 提取待落本地表的数据
         lcls = itfTblAzAssignLcLsDownloadService.lambdaQuery()
                 .eq(ItfTblAzAssignLcLsDownload::getSynStatus, SynStatusEnum.UN_SYN.getCode())
-                .lt(ItfTblAzAssignLcLsDownload::getSynTimes, 6)
+                .lt(ItfTblAzAssignLcLsDownload::getSynTimes, 3)
                 // .eq(ItfTblAzAssignLcLsDownload::getSynReqId,4051)// 测试使用
                 .orderByAsc(ItfTblAzAssignLcLsDownload::getSynReqId)
                 .list();

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

@@ -80,7 +80,7 @@ public class RepairBusinessApi {
         repairRec = itfTblAssignDownloadService.lambdaQuery()
                 .eq(ItfTblAssignDownload::getSynStatus, 0)
                 // .eq(ItfTblAssignDownload::getSynReqId, 1359)// 测试使用
-                .lt(ItfTblAssignDownload::getSynTimes, 6)
+                .lt(ItfTblAssignDownload::getSynTimes, 3)
                 .orderByAsc(ItfTblAssignDownload::getSynReqId)
                 .list();
 

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

@@ -92,6 +92,20 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 	OrderProductService orderProductService;
 	@Resource
 	ItfTblWxjsXxyyJyktDownloadService itfTblWxjsXxyyJyktDownloadService;
+	@Resource
+	OrderRepairDetailReasonService orderRepairDetailReasonService;
+	@Resource
+	RepairBugAppService repairBugAppService;
+	@Resource
+	OrderRepairDetailItemService orderRepairDetailItemService;
+	@Resource
+	ItfTblWxjsWxxmJyktDownloadService itfTblWxjsWxxmJyktDownloadService;
+	@Resource
+	ItfTblWxjsPjmxJyktDownloadService itfTblWxjsPjmxJyktDownloadService;
+	@Resource
+	ItfTblWxjsFjJyktDownloadService itfTblWxjsFjJyktDownloadService;
+
+
 
 	
 
@@ -231,7 +245,7 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 			processWxjsJykt(downloadTaskNo, pgguid);
 		} else if (downloadTaskType == 660101){
 			// 维修工单三子表下载  TL_SynDataFrom_tbl_wxjs_jykt_child
-			processwxjsJyktFj(downloadTaskNo, pgguid);
+			processSix(downloadTaskNo, pgguid);
 		}
 	}
 
@@ -367,7 +381,7 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 				List<OrderDetailFile> fs = orderDetailFileService.lambdaQuery()
 						.select(OrderDetailFile::getFjguid,OrderDetailFile::getFileType)
 						.eq(OrderDetailFile::getOrderBaseId,order.getId()).list();
-				if (CollectionUtils.isEmpty(fs)){
+				if (CollectionUtils.isNotEmpty(fs)){
 					fs.stream().forEach(event->{
 						fsFjguid.add(event.getFjguid());
 					});
@@ -394,87 +408,328 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 		upSynStatusAzJyktFJ(downloadTaskNo);
 	}
 
-	// pgguid = order_repair_detail.brand_wxjsguid    TL_SynDataFrom_tbl_wxjs_jykt_child
-	public void processwxjsJyktFj(String downloadTaskNo, String pgguid) {
-		List<OrderDetailFile> odfs = new ArrayList<>();
-		List<OrderInstallDetail> oids = new ArrayList<>();
-		Map<String,List<OrderInstallDetail>> oidsMap = new HashMap<>();
-		List<String> fsFjguid = new ArrayList<>();
-		if (1==1){
+	// pgguid = order_repair_detail.brand_wxjsguid
+	// TL_SynDataFrom_tbl_wxjs_jykt_child
+	// 四个方法放在一起处理 有一个处理完就要修改对应的task_list
+	public void processSix(String downloadTaskNo, String pgguid) {
+        // 维修现象下载同步   无数据时不处理同时修改同步状态
+		// TL_SynDataFrom_tbl_wxjs_xxyy_jykt
+		// itf_tbl_wxjs_xxyy_jykt_download   ->OrderRepairDetailReason
+		if (processWxJsXxyyJykt(downloadTaskNo,pgguid)) {
+			return;
+		}
+		// 维修项目现象 无数据时不处理同时修改同步状态
+		// TL_SynDataFrom_tbl_wxjs_wxxm_jykt
+		// itf_tbl_wxjs_wxxm_jykt_download  ->order_repair_detail_item
+		if (processWxJsWxxmJykt(downloadTaskNo,pgguid)) {
 			return;
 		}
 
-		// 维修现象下载记录 itf_tbl_wxjs_xxyy_jykt_download   ->OrderRepairDetailReason
+		// 配件表 无数据时不处理同时修改同步状态
+		// TL_SynDataFrom_tbl_wxjs_pjmx_jykt
+		// itf_tbl_wxjs_pjmx_jykt_download
+		processWxjsPjmxJykt(downloadTaskNo);
+
+		// 维修项目现象 无数据时不处理同时修改同步状态
+		// TL_SynDataFrom_tbl_wxjs_fj_jykt
+		// itf_tbl_wxjs_fj_jykt_download  ->order_detail_file
+		if (processWxJsFjJykt(downloadTaskNo,pgguid)) {
+			return;
+		}
+
+
+
+
+
+
+
+		// 修改同步状态
+		OrderPar req = new OrderPar();
+		req.setOrderNo(downloadTaskNo);
+		installDownloadTaskListMapper.updateSynStatus(req);
+	}
+
+
+	// pgguid = order_repair_detail.brand_wxjsguid
+	// TL_SynDataFrom_tbl_wxjs_jykt_child
+	// 四个方法放在一起处理 有一个处理完就要修改对应的task_list
+	public Boolean processWxJsXxyyJykt(String downloadTaskNo, String pgguid) {
+		List<OrderRepairDetailReason> ordrs = new ArrayList<>();
+		List<OrderRepairDetail> irds = new ArrayList<>();
+		Map<String,List<OrderRepairDetail>> irdsMap = new HashMap<>();
+		List<OrderRepairDetailReason> ordrsOld = new ArrayList<>();
+		List<String> xxyyguid = new ArrayList<>();
+
+		// 维修现象下载同步   无数据时不处理同时修改同步状态
+		// TL_SynDataFrom_tbl_wxjs_xxyy_jykt
+		// itf_tbl_wxjs_xxyy_jykt_download   ->OrderRepairDetailReason
 		List<ItfTblWxjsXxyyJyktDownload> wxxxs = itfTblWxjsXxyyJyktDownloadService.lambdaQuery()
 				.eq(ItfTblWxjsXxyyJyktDownload::getDownloadTaskNo,downloadTaskNo).list();
+
 		if (CollectionUtils.isNotEmpty(wxxxs)){
+			irds = orderRepairDetailService.lambdaQuery()
+					.eq(OrderRepairDetail::getBrandWxjsguid,pgguid).list();
+			// 无数据不处理
+			if (CollectionUtils.isEmpty(irds)) {
+				return Boolean.TRUE;
+			}
+
+			irdsMap = irds.stream().collect(Collectors.groupingBy(OrderRepairDetail::getBrandWxjsguid));
+
+			ordrsOld = orderRepairDetailReasonService.lambdaQuery()
+					.eq(OrderRepairDetailReason::getOrderBaseId,irds.get(0).getOrderBaseId()).list();
+
+			if (CollectionUtils.isEmpty(ordrsOld)){
+				ordrsOld.stream().forEach(event->{
+					xxyyguid.add(event.getXxyyguid());
+				});
+			}
 
+			// 生成故障现象数据 暂时忽略更新，无新增
+			for (ItfTblWxjsXxyyJyktDownload item:wxxxs){
+				if (xxyyguid.contains(item.getXxyyguid())){
+					continue;
+				}
+				getOrderRepairDetailReason(ordrs, irdsMap, item);
+			}
+
+			if (ordrs.size()>0) {
+				orderRepairDetailReasonService.saveBatch(ordrs);
+				ordrs.clear();
+			}
+			// 修改同步状态
+			upSynStatusWxjsXxyyJykt(downloadTaskNo);
 		}
+		return Boolean.FALSE;
+	}
 
+	// pgguid = order_repair_detail.brand_wxjsguid
+	// TL_SynDataFrom_tbl_wxjs_wxxm_jykt
+	// itf_tbl_wxjs_wxxm_jykt_download  ->order_repair_detail_item
+	public Boolean processWxJsWxxmJykt(String downloadTaskNo, String pgguid) {
+		List<OrderRepairDetailItem> ordrs = new ArrayList<>();
+		List<OrderRepairDetail> irds = new ArrayList<>();
+		Map<String,List<OrderRepairDetail>> irdsMap = new HashMap<>();
+		List<OrderRepairDetailItem> ordrsOld = new ArrayList<>();
+		List<String> wxjsguid = new ArrayList<>();
+		List<String> orderRepairDetailIds = new ArrayList<>();
+
+		// 维修现象下载同步   无数据时不处理同时修改同步状态
+		// TL_SynDataFrom_tbl_wxjs_wxxm_jykt
+		// itf_tbl_wxjs_wxxm_jykt_download   ->order_repair_detail_item
+		List<ItfTblWxjsWxxmJyktDownload> wxxms = itfTblWxjsWxxmJyktDownloadService.lambdaQuery()
+				.eq(ItfTblWxjsWxxmJyktDownload::getDownloadTaskNo,downloadTaskNo).list();
+
+		if (CollectionUtils.isNotEmpty(wxxms)){
+			irds = orderRepairDetailService.lambdaQuery()
+					.eq(OrderRepairDetail::getBrandWxjsguid,pgguid).list();
+			// 无数据不处理
+			if (CollectionUtils.isEmpty(irds)) {
+				return Boolean.TRUE;
+			}
 
+			if (CollectionUtils.isEmpty(irds)){
+				irds.stream().forEach(event->{
+					orderRepairDetailIds.add(event.getId());
+				});
+			}
 
 
+			irdsMap = irds.stream().collect(Collectors.groupingBy(OrderRepairDetail::getBrandWxjsguid));
 
+			ordrsOld = orderRepairDetailItemService.lambdaQuery()
+					.in(OrderRepairDetailItem::getOrderRepairDetailId,orderRepairDetailIds).list();
 
+			if (CollectionUtils.isEmpty(ordrsOld)){
+				ordrsOld.stream().forEach(event->{
+					wxjsguid.add(event.getWxjsguid());
+				});
+			}
 
+			// 生成维修现象数据 暂时忽略更新，无新增
+			for (ItfTblWxjsWxxmJyktDownload item:wxxms){
+				if (wxjsguid.contains(item.getWxxmguid())){
+					continue;
+				}
+				getOrderRepairDetailItem(ordrs, irdsMap, item);
+			}
 
+			if (ordrs.size()>0) {
+				orderRepairDetailItemService.saveBatch(ordrs);
+				ordrs.clear();
+			}
+			// 修改同步状态
+			upSynStatusWxJsWxxmJykt(downloadTaskNo);
+		}
+		return Boolean.FALSE;
+	}
 
+	// pgguid = order_repair_detail.brand_wxjsguid
+	// TL_SynDataFrom_tbl_wxjs_pjmx_jykt
+	// itf_tbl_wxjs_pjmx_jykt_download
+	public void processWxjsPjmxJykt(String downloadTaskNo) {
+		// 直接修改同步状态
+		upSynStatusWxjsPjmxJykt(downloadTaskNo);
+	}
 
+	// pgguid = order_repair_detail.brand_wxjsguid
+	// TL_SynDataFrom_tbl_wxjs_fj_jykt
+	// itf_tbl_wxjs_fj_jykt_download  ->order_detail_file
+	public Boolean processWxJsFjJykt(String downloadTaskNo, String pgguid) {
+		List<OrderDetailFile> ordrs = new ArrayList<>();
+		List<OrderRepairDetail> irds = new ArrayList<>();
+		Map<String,List<OrderRepairDetail>> irdsMap = new HashMap<>();
+		List<OrderDetailFile> ordrsOld = new ArrayList<>();
+		List<String> fjguid = new ArrayList<>();
+
+		// 维修现象下载同步   无数据时不处理同时修改同步状态
+		// TL_SynDataFrom_tbl_wxjs_fj_jykt
+		// itf_tbl_wxjs_fj_jykt_download   ->order_detail_file
+		List<ItfTblWxjsFjJyktDownload> wxjsfj = itfTblWxjsFjJyktDownloadService.lambdaQuery()
+				.eq(ItfTblWxjsFjJyktDownload::getDownloadTaskNo,downloadTaskNo).list();
+
+		if (CollectionUtils.isNotEmpty(wxjsfj)){
+			irds = orderRepairDetailService.lambdaQuery()
+					.eq(OrderRepairDetail::getBrandWxjsguid,pgguid).list();
+			// 无数据不处理
+			if (CollectionUtils.isEmpty(irds)) {
+				return Boolean.TRUE;
+			}
 
-		// 提取附件数据
-		List<ItfTblAzWgmxJyktFjDownload> jykts = itfTblAzWgmxJyktFjDownloadService.lambdaQuery()
-				.eq(ItfTblAzWgmxJyktFjDownload::getDownloadTaskNo, downloadTaskNo)
-				.eq(ItfTblAzWgmxJyktFjDownload::getSynStatus,0).list();
+			irdsMap = irds.stream().collect(Collectors.groupingBy(OrderRepairDetail::getBrandWxjsguid));
 
-		// 提取采集数据
-		oids = orderInstallDetailService.lambdaQuery()
-				.select(OrderInstallDetail::getPgwcmxid,OrderInstallDetail::getId)
-				.eq(OrderInstallDetail::getPgwcmxid,pgguid).list();
-		oidsMap = oids.stream().collect(Collectors.groupingBy(OrderInstallDetail::getPgwcmxid));
+			ordrsOld = orderDetailFileService.lambdaQuery()
+					.eq(OrderDetailFile::getOrderBaseId,irds.get(0).getOrderBaseId()).list();
 
-		if (!CollectionUtils.isEmpty(jykts)){
-			// 提取工单数据
-			OrderBase order = orderBaseService.lambdaQuery()
-					.eq(OrderBase::getId,oids.get(0).getOrderBaseId())
-					.last("limit 1").one();
-			if (order!=null){
-				// 提取现有的采集附件数据
-				List<OrderDetailFile> fs = orderDetailFileService.lambdaQuery()
-						.select(OrderDetailFile::getFjguid,OrderDetailFile::getFileType)
-						.eq(OrderDetailFile::getOrderBaseId,order.getId()).list();
-				if (CollectionUtils.isEmpty(fs)){
-					fs.stream().forEach(event->{
-						fsFjguid.add(event.getFjguid());
-					});
-				}
+			if (CollectionUtils.isEmpty(ordrsOld)){
+				ordrsOld.stream().forEach(event->{
+					fjguid.add(event.getFjguid());
+				});
+			}
 
-				for (ItfTblAzWgmxJyktFjDownload item :jykts){
-					// 采集明细表未同步不处理
-					if (!oidsMap.containsKey(item.getPgwcmxid())){
-						odfs.clear();
-						break;
-					}
-					// 生成采集附件明细数据 暂时忽略更新，无新增
-					if (!fsFjguid.contains(item.getFjguid())){
-						getItfTblAzWgmxJyktFj(odfs,oidsMap.get(item.getPgwcmxid()).get(0), order, item);
-					}
-				}
-				if (odfs.size()>0) {
-					orderDetailFileService.saveBatch(odfs);
-					odfs.clear();
+			// 生成维修现象数据 暂时忽略更新，无新增
+			for (ItfTblWxjsFjJyktDownload item:wxjsfj){
+				if (fjguid.contains(item.getFjguid())){
+					continue;
 				}
+				getOrderDetailFile(ordrs, irds, irdsMap, item);
+			}
+
+			if (ordrs.size()>0) {
+				orderDetailFileService.saveBatch(ordrs);
+				ordrs.clear();
 			}
+			// 修改同步状态
+			upSynStatusWxJsFjJykt(downloadTaskNo);
 		}
-		// 修改同步状态
-		upSynStatusAzJyktFJ(downloadTaskNo);
+		return Boolean.FALSE;
+	}
+
+	private void getOrderDetailFile(List<OrderDetailFile> ordrs, List<OrderRepairDetail> irds, Map<String, List<OrderRepairDetail>> irdsMap, ItfTblWxjsFjJyktDownload item) {
+		OrderDetailFile n = new OrderDetailFile();
+		n.setId(IdWorker.getIdStr());
+		n.setFjguid(item.getFjguid());
+		n.setOrderBaseId(irds.get(0).getOrderBaseId());
+		n.setOrderDetailId(irdsMap.get(item.getWxjsguid()).get(0).getId());
+		n.setFileType(21);
+		if (item.getTpms().equals("内机条码图像")){
+			n.setFileType(2);
+		} else if (item.getTpms().equals("外机条码图像")){
+			n.setFileType(5);
+		} else if (item.getTpms().equals("内机条码")){
+			n.setFileType(1);
+		} else if (item.getTpms().equals("外机条码")){
+			n.setFileType(3);
+		} else if (item.getTpms().equals("外机条码")){
+			n.setFileType(3);
+		} else if (item.getTpms().equals("故障位置图片")){
+			n.setFileType(20);
+		} else if (item.getTpms().equals("压力检测图片")){
+			n.setFileType(21);
+		} else if (item.getTpms().equals("旧压缩机条码")){
+			n.setFileType(26);
+		} else if (item.getTpms().equals("新压缩机条码")){
+			n.setFileType(27);
+		} else if (item.getTpms().equals("噪音视频")){
+			n.setFileType(28);
+		} else if (item.getTpms().equals("其他压力检测图片")){
+			n.setFileType(21);
+		} else if (item.getTpms().equals("其他故障位置图片")){
+			n.setFileType(20);
+		} else if (item.getTpms().equals("其他噪音视频")){
+			n.setFileType(29);
+		} else if (item.getTpms().equals("其他")){
+			n.setFileType(12);
+		}
+
+		if (item.getCreatedDate()!=null){
+			n.setCreateTime(item.getCreatedDate());
+		}
+		n.setCreateBy(item.getCreatedBy());
+		n.setUpdateBy(item.getLastModifiedBy());
+		if (item.getLastModifiedDate()!=null){
+			n.setUpdateTime(item.getLastModifiedDate());
+		}
+		ordrs.add(n);
+	}
+
+	private void getOrderRepairDetailItem(List<OrderRepairDetailItem> ordrs, Map<String, List<OrderRepairDetail>> irdsMap, ItfTblWxjsWxxmJyktDownload item) {
+		OrderRepairDetailItem n = new OrderRepairDetailItem();
+		n.setId(IdWorker.getIdStr());
+		n.setOrderRepairDetailId(irdsMap.get(item.getWxjsguid()).get(0).getId());
+
+		n.setWxjsguid(item.getWxxmguid());
+		n.setRepairItemNo(item.getWxxmh());
+		n.setRemark(item.getMshu());
+		n.setAmount(item.getWxfy());
+		n.setXxyyguid(item.getXxyyh());
+		if (item.getCreatedDate()!=null){
+			n.setCreateTime(item.getCreatedDate());
+		}
+		n.setCreateBy(item.getCreatedBy());
+		n.setUpdateBy(item.getLastModifiedBy());
+		if (item.getLastModifiedDate()!=null){
+			n.setUpdateTime(item.getLastModifiedDate());
+		}
+		ordrs.add(n);
+	}
+
+	private void getOrderRepairDetailReason(List<OrderRepairDetailReason> ordrs, Map<String, List<OrderRepairDetail>> irdsMap, ItfTblWxjsXxyyJyktDownload item) {
+		OrderRepairDetailReason n = new OrderRepairDetailReason();
+		n.setId(IdWorker.getIdStr());
+		n.setOrderRepairDetailId(irdsMap.get(item.getWxjsguid()).get(0).getId());
+		n.setXxyyguid(item.getXxyyguid());
+		n.setWxjsguid(item.getWxjsguid());
+		n.setRepairBugId("");
+		n.setRepairBugParentId("");
+		RepairBugApp rba = repairBugAppService.lambdaQuery()
+				.eq(RepairBugApp::getBugObjCode, item.getXxyyh())
+				.last("limit 1").one();
+		if (rba !=null){
+			n.setRepairBugId(rba.getBugId());
+			n.setRepairBugParentId(rba.getParentId());
+		}
+		n.setNumber(item.getXxyyh());
+		n.setName(item.getXxyyhmc());
+		n.setSortNum(item.getGzpx());
+		n.setRemark(item.getMshu());
+
+
+		if (item.getCreatedDate()!=null){
+			n.setCreateTime(item.getCreatedDate());
+		}
+		n.setCreateBy(item.getCreatedBy());
+		n.setUpdateBy(item.getLastModifiedBy());
+		if (item.getLastModifiedDate()!=null){
+			n.setUpdateTime(item.getLastModifiedDate());
+		}
+		ordrs.add(n);
 	}
 
 	// 维修工单这里放的为pgid
 	public void processWxjsJykt(String downloadTaskNo, String pgguid) {
 		List<OrderRepairDetail> ords = new ArrayList<>();
 		List<ItfGreeToFaDownloadTaskList> its = new ArrayList<>();
-		List<OrderInstallDetail> oids = new ArrayList<>();
-		Map<String,List<OrderInstallDetail>> oidsMap = new HashMap<>();
 		List<String> wxjsguid = new ArrayList<>();
 
 		// 提取维修结算表下载记录
@@ -522,7 +777,7 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 			}
 		}
 		// 修改同步状态
-		upSynStatusAzJyktFJ(downloadTaskNo);
+		upSynStatusWxJsJykt(downloadTaskNo);
 	}
 
 	private void getorderRepairDetail(List<OrderRepairDetail> ords, List<ItfGreeToFaDownloadTaskList> its, OrderBase order, OrderProduct op, ItfTblWxjsJyktDownload item) {
@@ -1329,9 +1584,60 @@ public class DetailDownloadServiceImpl implements DetailDownloadService {
 				.eq("download_task_no", downloadTaskNo)
 				.eq("syn_status",0);
 		itfTblAzWgmxJyktFjDownloadService.update(up,upWrapper);
+
+		installDownloadTaskListMapper.updateSynStatus(req);
+	}
+
+	public void upSynStatusWxJsJykt(String downloadTaskNo) {
+		OrderPar req = new OrderPar();
+		req.setOrderNo(downloadTaskNo);
+
+		ItfTblWxjsJyktDownload up = new ItfTblWxjsJyktDownload();
+		up.setSynStatus(1);
+		QueryWrapper upWrapper = new QueryWrapper<ItfTblWxjsJyktDownload>()
+				.eq("download_task_no", downloadTaskNo)
+				.eq("syn_status",0);
+		itfTblWxjsJyktDownloadService.update(up,upWrapper);
+
 		installDownloadTaskListMapper.updateSynStatus(req);
 	}
 
+	public void upSynStatusWxjsXxyyJykt(String downloadTaskNo) {
+		ItfTblWxjsXxyyJyktDownload up = new ItfTblWxjsXxyyJyktDownload();
+		up.setSynStatus(1);
+		QueryWrapper upWrapper = new QueryWrapper<ItfTblWxjsXxyyJyktDownload>()
+				.eq("download_task_no", downloadTaskNo)
+				.eq("syn_status",0);
+		itfTblWxjsXxyyJyktDownloadService.update(up,upWrapper);
+	}
+
+	public void upSynStatusWxJsWxxmJykt(String downloadTaskNo) {
+		ItfTblWxjsWxxmJyktDownload up = new ItfTblWxjsWxxmJyktDownload();
+		up.setSynStatus(1);
+		QueryWrapper upWrapper = new QueryWrapper<ItfTblWxjsWxxmJyktDownload>()
+				.eq("download_task_no", downloadTaskNo)
+				.eq("syn_status",0);
+		itfTblWxjsWxxmJyktDownloadService.update(up,upWrapper);
+	}
+
+	public void upSynStatusWxJsFjJykt(String downloadTaskNo) {
+		ItfTblWxjsFjJyktDownload up = new ItfTblWxjsFjJyktDownload();
+		up.setSynStatus(1);
+		QueryWrapper upWrapper = new QueryWrapper<ItfTblWxjsFjJyktDownload>()
+				.eq("download_task_no", downloadTaskNo)
+				.eq("syn_status",0);
+		itfTblWxjsFjJyktDownloadService.update(up,upWrapper);
+	}
+
+	public void upSynStatusWxjsPjmxJykt(String downloadTaskNo) {
+		ItfTblWxjsPjmxJyktDownload up = new ItfTblWxjsPjmxJyktDownload();
+		up.setSynStatus(99);
+		QueryWrapper upWrapper = new QueryWrapper<ItfTblWxjsPjmxJyktDownload>()
+				.eq("download_task_no", downloadTaskNo)
+				.eq("syn_status",0);
+		itfTblWxjsPjmxJyktDownloadService.update(up,upWrapper);
+	}
+
 	public void upSynStatusAzSyktFJ(String downloadTaskNo) {
 		ItfTblAzWgmxSyktFjDownload up = new ItfTblAzWgmxSyktFjDownload();
 		up.setSynStatus(1);