|
@@ -82,7 +82,7 @@ public class KdYdCustomerController {
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private HuaGaoService huaGaoService;
|
|
private HuaGaoService huaGaoService;
|
|
|
@PostMapping("/test")
|
|
@PostMapping("/test")
|
|
|
- public McR sendGroupMsg(@RequestBody JSONObject param) {
|
|
|
|
|
|
|
+ public McR sendGroupMsg(@RequestBody JSONObject param) throws Exception {
|
|
|
log.info("推送消息:{}", param);
|
|
log.info("推送消息:{}", param);
|
|
|
// MDC.put("MDC_KEY_PID", "1002");
|
|
// MDC.put("MDC_KEY_PID", "1002");
|
|
|
// McException.assertParamException_Null(param, "msgParam", "msgKey", "openConversationId", "robotCode", "coolAppCode");
|
|
// McException.assertParamException_Null(param, "msgParam", "msgKey", "openConversationId", "robotCode", "coolAppCode");
|
|
@@ -112,10 +112,44 @@ public class KdYdCustomerController {
|
|
|
// .build(),
|
|
// .build(),
|
|
|
// YDConf.FORM_OPERATION.multi_update
|
|
// YDConf.FORM_OPERATION.multi_update
|
|
|
// );
|
|
// );
|
|
|
|
|
+ K3CloudApi client = new K3CloudApi(initIden());
|
|
|
|
|
|
|
|
|
|
+ int startRow = 0;
|
|
|
|
|
+ int limit = 2000;
|
|
|
|
|
|
|
|
-// LocalDateTime startTime = LocalDate.of(2026, 10, 13).atStartOfDay();
|
|
|
|
|
-// LocalDateTime endTime = LocalDate.of(2026, 10, 14).atStartOfDay();
|
|
|
|
|
|
|
+ BillQuery billQuery = new BillQuery();
|
|
|
|
|
+
|
|
|
|
|
+ billQuery.setLimit(limit);
|
|
|
|
|
+ billQuery.setFormId("BD_SerialMainFile");
|
|
|
|
|
+ billQuery.setFieldKeys("FNumber,FMaterialID.FNumber,FMaterialID.FName,FMaterialID.FSpecification,FMaterialID.F_QUXZ_Assistant,FZKTS,FStockStatus,FStockId.FName,FStockLocID.FF100001.FName,FCustId.FName");
|
|
|
|
|
+ List<Map> filterString = new ArrayList<>();
|
|
|
|
|
+ //仓库等于成品仓 仓位等于默认仓位或样机仓位 在库状态等于待入库或在库
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockId.FName","67","成品仓","","","0"));//仓库名称等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockLocId.FF100001.FName","67","默认仓位","(","","0"));//仓位等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockLocId.FF100001.FName","67","讯飞皆成","","","1"));//仓位等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockLocId.FF100001.FName","67","讯飞天津租赁","","","1"));//仓位等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockLocId.FF100001.FName","67","讯飞知学","","","1"));//仓位等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockLocId.FF100001.FName","67","物流成品发货","","","1"));//仓位等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockLocId.FF100001.FName","67","样机仓位","",")","1"));//仓位等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockStatus","29","0","(","","0"));//在库状态等于XX
|
|
|
|
|
+ filterString.add(UtilMap.map("FieldName, Compare, Value, Left, Right, Logic","FStockStatus","29","1","",")","1"));//在库状态等于XX
|
|
|
|
|
+
|
|
|
|
|
+ billQuery.setFilterString(filterString);
|
|
|
|
|
+
|
|
|
|
|
+ List<Map> result = new ArrayList<>();
|
|
|
|
|
+ List<Map> list = new ArrayList<>();
|
|
|
|
|
+
|
|
|
|
|
+ do {
|
|
|
|
|
+ billQuery.setStartRow(startRow);
|
|
|
|
|
+ String s = client.billQuery(JSONObject.toJSONString(billQuery));
|
|
|
|
|
+ result = (List<Map>)JSONObject.parse(s);
|
|
|
|
|
+ list.addAll(result);
|
|
|
|
|
+
|
|
|
|
|
+ startRow += limit;
|
|
|
|
|
+ }while (result.size() == limit);
|
|
|
|
|
+ System.out.println(list.size());
|
|
|
|
|
+// LocalDateTime startTime = LocalDate.of(2026, 10, 27).atStartOfDay();
|
|
|
|
|
+// LocalDateTime endTime = LocalDate.of(2026, 10, 28 ).atStartOfDay();
|
|
|
// List<String> time = Arrays.asList(String.valueOf(UtilDateTime.getLocalDateTimeTimeStamp(startTime)), String.valueOf(UtilDateTime.getLocalDateTimeTimeStamp(endTime)));
|
|
// List<String> time = Arrays.asList(String.valueOf(UtilDateTime.getLocalDateTimeTimeStamp(startTime)), String.valueOf(UtilDateTime.getLocalDateTimeTimeStamp(endTime)));
|
|
|
// try {
|
|
// try {
|
|
|
// huaGaoService.syncKqData(startTime, endTime);
|
|
// huaGaoService.syncKqData(startTime, endTime);
|