|
@@ -479,41 +479,6 @@ public class dingshiqiImpl implements dingshiqi {
|
|
|
|
|
|
|
|
|
|
|
|
- @Autowired
|
|
|
- private YDService ydService;
|
|
|
|
|
|
- /**
|
|
|
- * 停用数据同步逻辑
|
|
|
- */
|
|
|
- @Override
|
|
|
- public void syncRecruitSource(String type) {
|
|
|
|
|
|
- Map mapForm = UtilMap.map("YWFL, YZDZ, YZWL", "FORM-417576F4EE9F4AA1B2395BCD93B7A08C8ASN", "FORM-6D5B2C469B45456F9287C3575BFF92C7KUF6", "FORM-7ACCB70D96FA4187BD2042243641E54CD6VH");
|
|
|
- String formUuid = UtilMap.getString(mapForm, type);
|
|
|
- McException.assertParamException(StringUtils.isBlank(formUuid), "同步数据档案不存在!");
|
|
|
- YDParam_T ydParamT = new YDParam_T();
|
|
|
- ydParamT.setFormUuid(formUuid);
|
|
|
- ydParamT.setSearchCondition(JSON.toJSONString(UtilMap.map("radioField_lznyvvav", "启用")));
|
|
|
- ydParamT.setModifiedToTimeGMT(UtilDateTime.formatDate(new Date(new Date().getTime() - 1 * 24 * 60 * 60 * 1000L)));
|
|
|
- List<Map> dataList = ydService.queryFormData_all(ydParamT);
|
|
|
- dataList.forEach(item -> {
|
|
|
- ydClient.operateData(YDParam.builder()
|
|
|
- .formInstanceId(UtilMap.getString(item, "instanceId"))
|
|
|
- .updateFormDataJson(JSON.toJSONString(UtilMap.map("radioField_lznyvvav", "停用")))
|
|
|
- .build(), YDConf.FORM_OPERATION.update);
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 同步数据公共方法, 手动 + 定时
|
|
|
- */
|
|
|
- @Override
|
|
|
- public void syncCommon(String type) {
|
|
|
-
|
|
|
- // todo 罗:: 判定不同来源, 这里触发原有逻辑同步, 添加同步时间和状态写入
|
|
|
-
|
|
|
-
|
|
|
- // 匹配停用数据做更新
|
|
|
- this.syncRecruitSource(type);
|
|
|
- }
|
|
|
}
|