|
@@ -1,6 +1,9 @@
|
|
|
package com.malk.huagao.service.impl;
|
|
package com.malk.huagao.service.impl;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
+import cn.hutool.http.HttpRequest;
|
|
|
|
|
+import cn.hutool.http.HttpResponse;
|
|
|
|
|
+import cn.hutool.http.HttpUtil;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
@@ -17,6 +20,7 @@ import com.malk.server.aliwork.YDSearch;
|
|
|
import com.malk.server.common.McR;
|
|
import com.malk.server.common.McR;
|
|
|
import com.malk.server.dingtalk.DDR_New;
|
|
import com.malk.server.dingtalk.DDR_New;
|
|
|
import com.malk.service.aliwork.YDClient;
|
|
import com.malk.service.aliwork.YDClient;
|
|
|
|
|
+import com.malk.utils.UtilHttp;
|
|
|
import com.malk.utils.UtilMap;
|
|
import com.malk.utils.UtilMap;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.slf4j.MDC;
|
|
import org.slf4j.MDC;
|
|
@@ -53,309 +57,303 @@ public class KdYdOrderServiceImpl extends ServiceImpl<KdYdOrderMapper, KdYdOrder
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public void insertkdYdOrder(Map map) {
|
|
|
|
|
- MDC.put("MDC_KEY_PID", "1003");
|
|
|
|
|
- String formInstId = UtilMap.getString(map, "formInstId");
|
|
|
|
|
- String type = UtilMap.getString(map, "type");
|
|
|
|
|
-
|
|
|
|
|
- if ("3".equals(type)) {
|
|
|
|
|
- String bm = UtilMap.getString(map, "bm");
|
|
|
|
|
- KdYdOrder kdYdOrder = new KdYdOrder();
|
|
|
|
|
- kdYdOrder.setOperationType("3");
|
|
|
|
|
- kdYdOrder.setSyncStatus("0");
|
|
|
|
|
- kdYdOrderMapper.update(kdYdOrder, new LambdaQueryWrapper<KdYdOrder>().eq(KdYdOrder::getDjbh, bm));
|
|
|
|
|
- return; // 或者根据你的业务逻辑返回相应的结果
|
|
|
|
|
- }
|
|
|
|
|
- if ("4".equals(type)) {
|
|
|
|
|
- String bm = UtilMap.getString(map, "bm");
|
|
|
|
|
- KdYdOrder kdYdOrder = new KdYdOrder();
|
|
|
|
|
- kdYdOrder.setOperationType("4");
|
|
|
|
|
- kdYdOrder.setSyncStatus("0");
|
|
|
|
|
- kdYdOrderMapper.update(kdYdOrder, new LambdaQueryWrapper<KdYdOrder>().eq(KdYdOrder::getDjbh, bm));
|
|
|
|
|
- return; // 或者根据你的业务逻辑返回相应的结果
|
|
|
|
|
- }
|
|
|
|
|
- DDR_New ddrNew = ydClient.queryData(YDParam.builder()
|
|
|
|
|
- .formInstId(formInstId)
|
|
|
|
|
- .build(), YDConf.FORM_QUERY.retrieve_id);
|
|
|
|
|
- Map formData = ddrNew.getFormData();
|
|
|
|
|
-
|
|
|
|
|
- String djlx = UtilMap.getString(formData, "selectField_mejowmna");
|
|
|
|
|
- String khmc = UtilMap.getString(formData, "textField_mejnamf2");
|
|
|
|
|
- String djbh = UtilMap.getString(formData, "textField_mjs6fuwo");
|
|
|
|
|
- if("2".equals(type)){
|
|
|
|
|
- djbh = UtilMap.getString(formData, "textField_mjs6fuwo");
|
|
|
|
|
- }
|
|
|
|
|
- LocalDateTime rq = parseTimestamp(UtilMap.getString(formData, "dateField_mejowmnb"));
|
|
|
|
|
- String khxypj = UtilMap.getString(formData, "selectField_mewirdx4");
|
|
|
|
|
- String ywlx = UtilMap.getString(formData, "textField_mfxv2vfz");
|
|
|
|
|
- String xsy = UtilMap.getString(formData, "employeeField_mejowmng").replace("[\"", "").replace("\"]", "").trim();
|
|
|
|
|
- String xslx = UtilMap.getString(formData, "selectField_mejowmnc");
|
|
|
|
|
- String bzq = UtilMap.getString(formData, "selectField_mf6gyfkq");
|
|
|
|
|
- String xsbm = UtilMap.getString(formData, "departmentSelectField_mfxv2vfu").replace("[\"", "").replace("\"]", "").trim();
|
|
|
|
|
- String bz = UtilMap.getString(formData, "textareaField_mejnamfb");
|
|
|
|
|
- String jsbb = UtilMap.getString(formData, "selectField_mejowmnk");
|
|
|
|
|
- String sktj = UtilMap.getString(formData, "selectField_mgisux07");
|
|
|
|
|
- String zdzkestr = UtilMap.getString(formData, "numberField_mejowmni");
|
|
|
|
|
- BigDecimal zdzke = toBigDecimal(zdzkestr);
|
|
|
|
|
-// String fj = UtilMap.getString(formData, "attachmentField_mfoqcctz");
|
|
|
|
|
-// JSONArray array = JSONObject.parseArray(fj);
|
|
|
|
|
-// List<String> resultList = new ArrayList<>();
|
|
|
|
|
-// if(array != null){
|
|
|
|
|
-// for (int i = 0; i < array.size(); i++) {
|
|
|
|
|
-// JSONObject jsonObject = array.getJSONObject(i);
|
|
|
|
|
-// String url = jsonObject.getString("url");
|
|
|
|
|
-// String s = ydClient.convertTemporaryUrl(url, 3600000);
|
|
|
|
|
-// resultList.add(s);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// if(StringUtils.isNotBlank(fj)){
|
|
|
|
|
-// List<Map> fjList =(List<Map>) JSON.parse(fj);
|
|
|
|
|
-// resultList.add(ydClient.convertTemporaryUrl(UtilMap.getString(fjList.get(0),"url"), 3600000));
|
|
|
|
|
-// }
|
|
|
|
|
- String sestr = UtilMap.getString(formData, "numberField_mfxv2vgh");
|
|
|
|
|
- BigDecimal se = toBigDecimal(sestr);
|
|
|
|
|
- String jestr = UtilMap.getString(formData, "numberField_mfxv2vgj");
|
|
|
|
|
- BigDecimal je = toBigDecimal(jestr);
|
|
|
|
|
- String jshjstr = UtilMap.getString(formData, "numberField_mewfgzkv");
|
|
|
|
|
- BigDecimal jshj = toBigDecimal(jshjstr);
|
|
|
|
|
- String sfhs = UtilMap.getString(formData, "radioField_mfxv2vg4");
|
|
|
|
|
- String jws = UtilMap.getString(formData, "radioField_mfxv2vgm");
|
|
|
|
|
- List<Map> tableField = (List<Map>) formData.get("tableField_mfbx1pqi");
|
|
|
|
|
- List<Map> tableFieldPayment = (List<Map>) formData.get("tableField_mhiui6v5");
|
|
|
|
|
-
|
|
|
|
|
- KdYdOrder kdYdOrder = new KdYdOrder();
|
|
|
|
|
- kdYdOrder.setDjlx(djlx);
|
|
|
|
|
- kdYdOrder.setDjbh(djbh);
|
|
|
|
|
- kdYdOrder.setKhmc(khmc);
|
|
|
|
|
- kdYdOrder.setRq(rq);
|
|
|
|
|
- kdYdOrder.setKhxypj(khxypj);
|
|
|
|
|
- kdYdOrder.setYwlx(ywlx);
|
|
|
|
|
- kdYdOrder.setXslx(xslx);
|
|
|
|
|
- kdYdOrder.setBzq(bzq);
|
|
|
|
|
- kdYdOrder.setXsy(xsy);
|
|
|
|
|
- kdYdOrder.setXsbm(xsbm);
|
|
|
|
|
- kdYdOrder.setBz(bz);
|
|
|
|
|
- kdYdOrder.setJsbb(jsbb);
|
|
|
|
|
- kdYdOrder.setSktj(sktj);
|
|
|
|
|
- kdYdOrder.setZdzke(zdzke);
|
|
|
|
|
- kdYdOrder.setSe(se);
|
|
|
|
|
- kdYdOrder.setJe(je);
|
|
|
|
|
- kdYdOrder.setJshj(jshj);
|
|
|
|
|
- kdYdOrder.setSfhs(sfhs);
|
|
|
|
|
- kdYdOrder.setJws(jws);
|
|
|
|
|
- kdYdOrder.setSyncStatus("0");
|
|
|
|
|
-
|
|
|
|
|
- Long id;
|
|
|
|
|
- if ("2".equals(type)) {
|
|
|
|
|
- // 查询已存在的订单
|
|
|
|
|
- KdYdOrder existing = kdYdOrderMapper.selectOne(
|
|
|
|
|
- new LambdaQueryWrapper<KdYdOrder>().eq(KdYdOrder::getDjbh, djbh)
|
|
|
|
|
- );
|
|
|
|
|
- if (existing == null) {
|
|
|
|
|
- throw new IllegalArgumentException("无法更新订单:单据编号 [" + djbh + "] 不存在");
|
|
|
|
|
|
|
+ public Map<String, Object> insertkdYdOrder(Map map) {
|
|
|
|
|
+ Map<String, Object> result = new HashMap<>();
|
|
|
|
|
+
|
|
|
|
|
+ try {
|
|
|
|
|
+ MDC.put("MDC_KEY_PID", "1003");
|
|
|
|
|
+ String formInstId = UtilMap.getString(map, "formInstId");
|
|
|
|
|
+ String type = UtilMap.getString(map, "type");
|
|
|
|
|
+
|
|
|
|
|
+ // 处理特殊操作类型
|
|
|
|
|
+ if ("del".equals(type)) {
|
|
|
|
|
+ String bm = UtilMap.getString(map, "bm");
|
|
|
|
|
+ Map<String, String> headers = new HashMap<>();
|
|
|
|
|
+ headers.put("Content-Type", "application/x-www-form-urlencoded");
|
|
|
|
|
+ Map<String, Object> formParams = new HashMap<>();
|
|
|
|
|
+ Map<String, Object> djbh = new HashMap<>();
|
|
|
|
|
+ djbh.put("djbh", bm);
|
|
|
|
|
+ result.put("data", djbh);
|
|
|
|
|
+ String jsonStr = JSON.toJSONString(result);
|
|
|
|
|
+
|
|
|
|
|
+ formParams.put("jsons", jsonStr);
|
|
|
|
|
+
|
|
|
|
|
+ System.out.println("====" + formParams);
|
|
|
|
|
+ HttpResponse response = HttpRequest.post("http://113.45.187.194:70/xk/dyzn/WsBasedyzn.asmx/hgdjydtbdeletexsdd")
|
|
|
|
|
+ .headerMap(headers, true)
|
|
|
|
|
+ .form(formParams)
|
|
|
|
|
+ .timeout(30000) // 30秒超时
|
|
|
|
|
+ .execute();
|
|
|
|
|
+
|
|
|
|
|
+ String responseBody = response.body();
|
|
|
|
|
+ // 返回删除操作的格式
|
|
|
|
|
+ result.put("table", "KD_YD_ORDER");
|
|
|
|
|
+ result.put("action", "del");
|
|
|
|
|
+ result.put("data", new HashMap<String, Object>() {{
|
|
|
|
|
+ put("bm", bm); // 删除的主键或标识
|
|
|
|
|
+ put("msg", "删除成功");
|
|
|
|
|
+ }});
|
|
|
|
|
+ return result;
|
|
|
}
|
|
}
|
|
|
- id = existing.getId();
|
|
|
|
|
- kdYdOrder.setId(id);
|
|
|
|
|
- kdYdOrder.setOperationType("2");
|
|
|
|
|
- kdYdOrderMapper.updateById(kdYdOrder); // 使用 updateById 更安全
|
|
|
|
|
- } else {
|
|
|
|
|
- kdYdOrder.setOperationType("1");
|
|
|
|
|
- kdYdOrderMapper.insert(kdYdOrder);
|
|
|
|
|
- id = kdYdOrder.getId(); // MyBatis-Plus 会自动回填主键
|
|
|
|
|
- }
|
|
|
|
|
|
|
|
|
|
-// ====== 1. 获取数据库中当前 orderId 的所有明细(用于后续对比删除)======
|
|
|
|
|
- LambdaQueryWrapper<KdYdOrderDetail> existingWrapper = new LambdaQueryWrapper<>();
|
|
|
|
|
- existingWrapper.eq(KdYdOrderDetail::getOrderId, id);
|
|
|
|
|
- List<KdYdOrderDetail> existingDetails = kdYdOrderDetailMapper.selectList(existingWrapper);
|
|
|
|
|
- Set<Integer> incomingDetailIds = new HashSet<>(); // 用于记录本次传入的 detailId
|
|
|
|
|
-
|
|
|
|
|
-// ====== 2. 遍历传入的 tableField,逐条处理 ======
|
|
|
|
|
- if (tableField != null) {
|
|
|
|
|
-// for (Map item : tableField) {
|
|
|
|
|
-// int detailId = parseInt(safeGetString(item, "indexField"), 0); // 建议前端传一个明确的 index 或 detailId 字段
|
|
|
|
|
-// // 如果前端没有显式传 detailId,可以用循环计数(但需注意顺序稳定性)
|
|
|
|
|
-// // 这里假设你用 count 作为 detailId(与前端一致)
|
|
|
|
|
-// // 若前端表格支持拖拽/乱序,建议传唯一行ID,但你当前用的是序号,我们继续用 count
|
|
|
|
|
-//
|
|
|
|
|
-// // 注意:你原代码用 count++,这里我们改用从数据中获取或维持顺序
|
|
|
|
|
-// // 为兼容你原有逻辑,我们仍用递增序号,但更推荐前端传 detailId
|
|
|
|
|
-// }
|
|
|
|
|
-
|
|
|
|
|
- // 重新遍历,使用 index 作为 detailId
|
|
|
|
|
- for (int i = 0; i < tableField.size(); i++) {
|
|
|
|
|
- Map item = tableField.get(i);
|
|
|
|
|
- int detailId = parseInt(safeGetString(item, "numberField_mjzfodew"), 0);
|
|
|
|
|
- incomingDetailIds.add(detailId);
|
|
|
|
|
-
|
|
|
|
|
- String wlbm = safeGetString(item, "textField_mfbx1pqt");
|
|
|
|
|
- String wlmc = safeGetString(item, "textField_mfbx1pqs");
|
|
|
|
|
- String ggxh = safeGetString(item, "textField_mfbx1pqr");
|
|
|
|
|
- String xsdw = safeGetString(item, "textField_mfbx1pqq");
|
|
|
|
|
- int xssl = parseInt(safeGetString(item, "numberField_mfbx1pr4"), 0);
|
|
|
|
|
- String ssxl = safeGetString(item, "selectField_mfbx1pr1");
|
|
|
|
|
- BigDecimal dj = toBigDecimal(safeGetString(item, "numberField_mfbx1prf"));
|
|
|
|
|
- BigDecimal cxzkje = toBigDecimal(safeGetString(item, "numberField_mk56soin"));
|
|
|
|
|
- BigDecimal hsdj = toBigDecimal(safeGetString(item, "numberField_mfbx1prg"));
|
|
|
|
|
- String sfzp = safeGetString(item, "radioField_mfbx1prc");
|
|
|
|
|
- String bz1 = safeGetString(item, "textareaField_mjryuaok");
|
|
|
|
|
- int sl = parseInt(safeGetString(item, "numberField_mfbx1prb"), 0);
|
|
|
|
|
- BigDecimal zse = toBigDecimal(safeGetString(item, "numberField_mfbx1prh"));
|
|
|
|
|
- BigDecimal zje = toBigDecimal(safeGetString(item, "numberField_mfbx1pri"));
|
|
|
|
|
- BigDecimal zjshj = toBigDecimal(safeGetString(item, "numberField_mfbx1prj"));
|
|
|
|
|
- BigDecimal jj = toBigDecimal(safeGetString(item, "numberField_mfbx1prk"));
|
|
|
|
|
- BigDecimal zkl = toBigDecimal(safeGetString(item, "numberField_mfbx1pru"));
|
|
|
|
|
- BigDecimal zke = toBigDecimal(safeGetString(item, "numberField_mfbx1prt"));
|
|
|
|
|
- LocalDateTime yhrq = parseTimestamp(UtilMap.getString(item, "dateField_mfbx1prs"));
|
|
|
|
|
- BigDecimal xsjzj = toBigDecimal(safeGetString(item, "numberField_mfbx1pr0"));
|
|
|
|
|
- String zmzs = safeGetString(item, "textField_mfxv2vgv");
|
|
|
|
|
-
|
|
|
|
|
- // 查询是否已存在
|
|
|
|
|
- LambdaQueryWrapper<KdYdOrderDetail> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
|
- queryWrapper.eq(KdYdOrderDetail::getOrderId, id)
|
|
|
|
|
- .eq(KdYdOrderDetail::getDetailId, detailId);
|
|
|
|
|
- KdYdOrderDetail existing = kdYdOrderDetailMapper.selectOne(queryWrapper);
|
|
|
|
|
-
|
|
|
|
|
- if (existing != null) {
|
|
|
|
|
- // 更新
|
|
|
|
|
- existing.setWlbm(wlbm);
|
|
|
|
|
- existing.setWlmc(wlmc);
|
|
|
|
|
- existing.setGgxh(ggxh);
|
|
|
|
|
- existing.setXsdw(xsdw);
|
|
|
|
|
- existing.setXssl(xssl);
|
|
|
|
|
- existing.setSsxl(ssxl);
|
|
|
|
|
- existing.setCxzkje(cxzkje);
|
|
|
|
|
- existing.setDj(dj);
|
|
|
|
|
- existing.setHsdj(hsdj);
|
|
|
|
|
- existing.setSfzp(sfzp);
|
|
|
|
|
- existing.setSl(sl);
|
|
|
|
|
- existing.setBz(bz1);
|
|
|
|
|
- existing.setSe(zse);
|
|
|
|
|
- existing.setJe(zje);
|
|
|
|
|
- existing.setJshj(zjshj);
|
|
|
|
|
- existing.setJj(jj);
|
|
|
|
|
- existing.setZkl(zkl);
|
|
|
|
|
- existing.setZke(zke);
|
|
|
|
|
- existing.setYhrq(yhrq);
|
|
|
|
|
- existing.setXsjzj(xsjzj);
|
|
|
|
|
- existing.setSmzs(zmzs);
|
|
|
|
|
- existing.setSyncStatus("0");
|
|
|
|
|
- existing.setOperationType(type); // 注意:type 决定是 insert(1) 还是 update(2/3)
|
|
|
|
|
-
|
|
|
|
|
- kdYdOrderDetailMapper.updateById(existing);
|
|
|
|
|
- } else {
|
|
|
|
|
- // 新增
|
|
|
|
|
- KdYdOrderDetail kdYdOrderDetail = new KdYdOrderDetail();
|
|
|
|
|
- kdYdOrderDetail.setOrderId(id);
|
|
|
|
|
- kdYdOrderDetail.setDetailId(detailId);
|
|
|
|
|
- kdYdOrderDetail.setWlbm(wlbm);
|
|
|
|
|
- kdYdOrderDetail.setCxzkje(cxzkje);
|
|
|
|
|
- kdYdOrderDetail.setWlmc(wlmc);
|
|
|
|
|
- kdYdOrderDetail.setGgxh(ggxh);
|
|
|
|
|
- kdYdOrderDetail.setXsdw(xsdw);
|
|
|
|
|
- kdYdOrderDetail.setXssl(xssl);
|
|
|
|
|
- kdYdOrderDetail.setSsxl(ssxl);
|
|
|
|
|
- kdYdOrderDetail.setDj(dj);
|
|
|
|
|
- kdYdOrderDetail.setHsdj(hsdj);
|
|
|
|
|
- kdYdOrderDetail.setSfzp(sfzp);
|
|
|
|
|
- kdYdOrderDetail.setSl(sl);
|
|
|
|
|
- kdYdOrderDetail.setSe(zse);
|
|
|
|
|
- kdYdOrderDetail.setJe(zje);
|
|
|
|
|
- kdYdOrderDetail.setBz(bz1);
|
|
|
|
|
- kdYdOrderDetail.setJshj(zjshj);
|
|
|
|
|
- kdYdOrderDetail.setJj(jj);
|
|
|
|
|
- kdYdOrderDetail.setZkl(zkl);
|
|
|
|
|
- kdYdOrderDetail.setZke(zke);
|
|
|
|
|
- kdYdOrderDetail.setYhrq(yhrq);
|
|
|
|
|
- kdYdOrderDetail.setXsjzj(xsjzj);
|
|
|
|
|
- kdYdOrderDetail.setSmzs(zmzs);
|
|
|
|
|
- kdYdOrderDetail.setSyncStatus("0");
|
|
|
|
|
- kdYdOrderDetail.setOperationType("1"); // 新增始终是 1
|
|
|
|
|
-
|
|
|
|
|
- kdYdOrderDetailMapper.insert(kdYdOrderDetail);
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ if ("cancel".equals(type)) {
|
|
|
|
|
+ String bm = UtilMap.getString(map, "bm");
|
|
|
|
|
+ Map<String, String> headers = new HashMap<>();
|
|
|
|
|
+ headers.put("Content-Type", "application/x-www-form-urlencoded");
|
|
|
|
|
+ Map<String, Object> formParams = new HashMap<>();
|
|
|
|
|
+ Map<String, Object> djbh = new HashMap<>();
|
|
|
|
|
+ djbh.put("djbh", bm);
|
|
|
|
|
+ result.put("data", djbh);
|
|
|
|
|
+ String jsonStr = JSON.toJSONString(result);
|
|
|
|
|
+ System.out.println("==" + jsonStr);
|
|
|
|
|
+ formParams.put("jsons", jsonStr);
|
|
|
|
|
+ HttpResponse response = HttpRequest.post("http://113.45.187.194:70/xk/dyzn/WsBasedyzn.asmx/hgdjydtbExcuteOperationxsdd")
|
|
|
|
|
+ .headerMap(headers, true)
|
|
|
|
|
+ .form(formParams)
|
|
|
|
|
+ .timeout(30000) // 30秒超时
|
|
|
|
|
+ .execute();
|
|
|
|
|
+
|
|
|
|
|
+ String responseBody = response.body();
|
|
|
|
|
+ String msg = JSON.parseArray(responseBody)
|
|
|
|
|
+ .getJSONObject(0)
|
|
|
|
|
+ .getString("msg");
|
|
|
|
|
+ ydClient.operateData(
|
|
|
|
|
+ YDParam.builder()
|
|
|
|
|
+ .formInstanceId(formInstId)
|
|
|
|
|
+ .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textareaField_mkxqgrvq", msg)))
|
|
|
|
|
+ .useLatestVersion(true).build(),
|
|
|
|
|
+ YDConf.FORM_OPERATION.update);
|
|
|
|
|
+ // 返回作废操作的格式
|
|
|
|
|
+ result.put("table", "KD_YD_ORDER");
|
|
|
|
|
+ result.put("action", "cancel"); // 作废通常是修改状态
|
|
|
|
|
+ result.put("data", new HashMap<String, Object>() {{
|
|
|
|
|
+ put("bm", bm); // 作废状态
|
|
|
|
|
+ put("msg", "作废成功");
|
|
|
|
|
+ // 其他作废需要的数据
|
|
|
|
|
+ }});
|
|
|
|
|
+ return result;
|
|
|
}
|
|
}
|
|
|
- }
|
|
|
|
|
|
|
|
|
|
-// ====== 3. 删除数据库中存在但本次未传入的明细 ======
|
|
|
|
|
- for (KdYdOrderDetail existing : existingDetails) {
|
|
|
|
|
- if (!incomingDetailIds.contains(existing.getDetailId())) {
|
|
|
|
|
- kdYdOrderDetailMapper.deleteById(existing.getId());
|
|
|
|
|
- // 或者软删除:update sync_status = '9' 等
|
|
|
|
|
|
|
+ // 查询表单数据
|
|
|
|
|
+ DDR_New ddrNew = ydClient.queryData(YDParam.builder()
|
|
|
|
|
+ .formInstId(formInstId)
|
|
|
|
|
+ .build(), YDConf.FORM_QUERY.retrieve_id);
|
|
|
|
|
+ Map formData = ddrNew.getFormData();
|
|
|
|
|
+
|
|
|
|
|
+ // 提取主表字段
|
|
|
|
|
+ String djlx = UtilMap.getString(formData, "selectField_mejowmna");
|
|
|
|
|
+ String khmc = UtilMap.getString(formData, "textField_mejnamf2");
|
|
|
|
|
+// String khmc = "五岳";
|
|
|
|
|
+// String djbh = UtilMap.getString(formData, "textField_mjs6fuwo");
|
|
|
|
|
+
|
|
|
|
|
+ // 判断操作类型对应的action
|
|
|
|
|
+ String actionType;
|
|
|
|
|
+ String djbh = null;
|
|
|
|
|
+ if ("edit".equals(type)) {
|
|
|
|
|
+ djbh = UtilMap.getString(formData, "textField_mjs6fuwo");
|
|
|
|
|
+ actionType = "edit";
|
|
|
|
|
+ } else {
|
|
|
|
|
+ actionType = "add";
|
|
|
|
|
+ djbh = "";
|
|
|
}
|
|
}
|
|
|
- }
|
|
|
|
|
|
|
|
|
|
-// ====== 处理付款计划子表(KdYdOrderPayment)======
|
|
|
|
|
-
|
|
|
|
|
-// 1. 查询数据库中当前 orderId 下所有已存在的付款记录
|
|
|
|
|
- LambdaQueryWrapper<KdYdOrderPayment> paymentExistingWrapper = new LambdaQueryWrapper<>();
|
|
|
|
|
- paymentExistingWrapper.eq(KdYdOrderPayment::getOrderId, id);
|
|
|
|
|
- List<KdYdOrderPayment> existingPayments = kdYdOrderPaymentMapper.selectList(paymentExistingWrapper);
|
|
|
|
|
- Set<Integer> incomingPaymentDetailIds = new HashSet<>();
|
|
|
|
|
-
|
|
|
|
|
- if (tableFieldPayment != null) {
|
|
|
|
|
- for (int i = 0; i < tableFieldPayment.size(); i++) {
|
|
|
|
|
- Map row = tableFieldPayment.get(i);
|
|
|
|
|
- int detailId = i + 1; // 使用 1-based 序号作为 detailId(需与前端表格顺序一致)
|
|
|
|
|
- incomingPaymentDetailIds.add(detailId);
|
|
|
|
|
-
|
|
|
|
|
- String sfys = safeGetString(row, "radioField_mhiui6v7");
|
|
|
|
|
- String gldh = safeGetString(row, "textField_mhiui6va");
|
|
|
|
|
- BigDecimal ysbl = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6v6"));
|
|
|
|
|
- BigDecimal ysje = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6v8"));
|
|
|
|
|
- BigDecimal ssje = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6vb"));
|
|
|
|
|
- LocalDateTime endTime = parseTimestamp(UtilMap.getString(row, "dateField_mhiui6v9"));
|
|
|
|
|
-
|
|
|
|
|
- // 查询是否已存在该 (orderId, detailId)
|
|
|
|
|
- LambdaQueryWrapper<KdYdOrderPayment> queryWrapper = new LambdaQueryWrapper<>();
|
|
|
|
|
- queryWrapper.eq(KdYdOrderPayment::getOrderId, id)
|
|
|
|
|
- .eq(KdYdOrderPayment::getDetailId, detailId);
|
|
|
|
|
- KdYdOrderPayment existingPayment = kdYdOrderPaymentMapper.selectOne(queryWrapper);
|
|
|
|
|
-
|
|
|
|
|
- if (existingPayment != null) {
|
|
|
|
|
- // 更新
|
|
|
|
|
- existingPayment.setSfys(sfys);
|
|
|
|
|
- existingPayment.setGldh(gldh);
|
|
|
|
|
- existingPayment.setYsbl(ysbl);
|
|
|
|
|
- existingPayment.setYsje(ysje);
|
|
|
|
|
- existingPayment.setSsje(ssje);
|
|
|
|
|
- existingPayment.setEndTime(endTime);
|
|
|
|
|
- existingPayment.setSyncStatus("0");
|
|
|
|
|
- existingPayment.setOperationType(type); // 使用传入的 type("2" 或 "3")
|
|
|
|
|
-
|
|
|
|
|
- kdYdOrderPaymentMapper.updateById(existingPayment);
|
|
|
|
|
- } else {
|
|
|
|
|
- // 新增
|
|
|
|
|
- KdYdOrderPayment payment = new KdYdOrderPayment();
|
|
|
|
|
- payment.setOrderId(id);
|
|
|
|
|
- payment.setDetailId(detailId);
|
|
|
|
|
- payment.setSfys(sfys);
|
|
|
|
|
- payment.setGldh(gldh);
|
|
|
|
|
- payment.setYsbl(ysbl);
|
|
|
|
|
- payment.setYsje(ysje);
|
|
|
|
|
- payment.setSsje(ssje);
|
|
|
|
|
- payment.setEndTime(endTime);
|
|
|
|
|
- payment.setSyncStatus("0");
|
|
|
|
|
- payment.setOperationType("1"); // 新增操作类型为 "1"
|
|
|
|
|
-
|
|
|
|
|
- kdYdOrderPaymentMapper.insert(payment);
|
|
|
|
|
|
|
+ // 提取其他字段...
|
|
|
|
|
+ LocalDateTime rq = parseTimestamp(UtilMap.getString(formData, "dateField_mejowmnb"));
|
|
|
|
|
+ String khxypj = UtilMap.getString(formData, "selectField_mewirdx4");
|
|
|
|
|
+ String ywlx = UtilMap.getString(formData, "textField_mfxv2vfz");
|
|
|
|
|
+ String xsy = UtilMap.getString(formData, "employeeField_mejowmng").replace("[\"", "").replace("\"]", "").trim();
|
|
|
|
|
+ String xslx = UtilMap.getString(formData, "selectField_mejowmnc");
|
|
|
|
|
+ String bzq = UtilMap.getString(formData, "selectField_mf6gyfkq");
|
|
|
|
|
+ String xsbm = UtilMap.getString(formData, "departmentSelectField_mfxv2vfu").replace("[\"", "").replace("\"]", "").trim();
|
|
|
|
|
+ String bz = UtilMap.getString(formData, "textareaField_mejnamfb");
|
|
|
|
|
+ String jsbb = UtilMap.getString(formData, "selectField_mejowmnk");
|
|
|
|
|
+ String sktj = UtilMap.getString(formData, "selectField_mgisux07");
|
|
|
|
|
+ String zdzkestr = UtilMap.getString(formData, "numberField_mejowmni");
|
|
|
|
|
+ BigDecimal zdzke = toBigDecimal(zdzkestr);
|
|
|
|
|
+ String sestr = UtilMap.getString(formData, "numberField_mfxv2vgh");
|
|
|
|
|
+ BigDecimal se = toBigDecimal(sestr);
|
|
|
|
|
+ String jestr = UtilMap.getString(formData, "numberField_mfxv2vgj");
|
|
|
|
|
+ BigDecimal je = toBigDecimal(jestr);
|
|
|
|
|
+ String jshjstr = UtilMap.getString(formData, "numberField_mewfgzkv");
|
|
|
|
|
+ BigDecimal jshj = toBigDecimal(jshjstr);
|
|
|
|
|
+ String sfhs = UtilMap.getString(formData, "radioField_mfxv2vg4");
|
|
|
|
|
+ String jws = UtilMap.getString(formData, "radioField_mfxv2vgm");
|
|
|
|
|
+ List<Map> tableField = (List<Map>) formData.get("tableField_mfbx1pqi");
|
|
|
|
|
+ List<Map> tableFieldPayment = (List<Map>) formData.get("tableField_mhiui6v5");
|
|
|
|
|
+
|
|
|
|
|
+ // 处理订单明细
|
|
|
|
|
+ List<Map<String, Object>> orderList = new ArrayList<>();
|
|
|
|
|
+ if (tableField != null) {
|
|
|
|
|
+ for (int i = 0; i < tableField.size(); i++) {
|
|
|
|
|
+ Map item = tableField.get(i);
|
|
|
|
|
+ Map<String, Object> table1Map = new HashMap<>();
|
|
|
|
|
+
|
|
|
|
|
+ int detailId = parseInt(safeGetString(item, "numberField_mjzfodew"), 0);
|
|
|
|
|
+ String wlbm = safeGetString(item, "textField_mfbx1pqt");
|
|
|
|
|
+// String wlbm = "010101010003";
|
|
|
|
|
+ String wlmc = safeGetString(item, "textField_mfbx1pqs");
|
|
|
|
|
+ String ggxh = safeGetString(item, "textField_mfbx1pqr");
|
|
|
|
|
+ String xsdw = safeGetString(item, "textField_mfbx1pqq");
|
|
|
|
|
+ int xssl = parseInt(safeGetString(item, "numberField_mfbx1pr4"), 0);
|
|
|
|
|
+ String ssxl = safeGetString(item, "selectField_mfbx1pr1");
|
|
|
|
|
+ BigDecimal dj = toBigDecimal(safeGetString(item, "numberField_mfbx1prf"));
|
|
|
|
|
+ BigDecimal cxzkje = toBigDecimal(safeGetString(item, "numberField_mk56soin"));
|
|
|
|
|
+ BigDecimal hsdj = toBigDecimal(safeGetString(item, "numberField_mfbx1prg"));
|
|
|
|
|
+ String sfzp = safeGetString(item, "radioField_mfbx1prc");
|
|
|
|
|
+ String bz1 = safeGetString(item, "textareaField_mjryuaok");
|
|
|
|
|
+ int sl = parseInt(safeGetString(item, "numberField_mfbx1prb"), 0);
|
|
|
|
|
+ BigDecimal zse = toBigDecimal(safeGetString(item, "numberField_mfbx1prh"));
|
|
|
|
|
+ BigDecimal zje = toBigDecimal(safeGetString(item, "numberField_mfbx1pri"));
|
|
|
|
|
+ BigDecimal zjshj = toBigDecimal(safeGetString(item, "numberField_mfbx1prj"));
|
|
|
|
|
+ BigDecimal jj = toBigDecimal(safeGetString(item, "numberField_mfbx1prk"));
|
|
|
|
|
+ BigDecimal zkl = toBigDecimal(safeGetString(item, "numberField_mfbx1pru"));
|
|
|
|
|
+ BigDecimal zke = toBigDecimal(safeGetString(item, "numberField_mfbx1prt"));
|
|
|
|
|
+ LocalDateTime yhrq = parseTimestamp(UtilMap.getString(item, "dateField_mfbx1prs"));
|
|
|
|
|
+ BigDecimal xsjzj = toBigDecimal(safeGetString(item, "numberField_mfbx1pr0"));
|
|
|
|
|
+ String zmzs = safeGetString(item, "textField_mfxv2vgv");
|
|
|
|
|
+
|
|
|
|
|
+ // 设置明细字段
|
|
|
|
|
+ table1Map.put("detailId", detailId);
|
|
|
|
|
+ table1Map.put("wlbm", wlbm);
|
|
|
|
|
+ table1Map.put("wlmc", wlmc);
|
|
|
|
|
+ table1Map.put("ggxh", ggxh);
|
|
|
|
|
+ table1Map.put("xsdw", xsdw);
|
|
|
|
|
+ table1Map.put("xssl", xssl);
|
|
|
|
|
+ table1Map.put("ssxl", ssxl);
|
|
|
|
|
+ table1Map.put("dj", dj);
|
|
|
|
|
+ table1Map.put("cxzkje", cxzkje);
|
|
|
|
|
+ table1Map.put("hsdj", hsdj);
|
|
|
|
|
+ table1Map.put("sfzp", sfzp);
|
|
|
|
|
+ table1Map.put("bz", bz1);
|
|
|
|
|
+ table1Map.put("sl", sl);
|
|
|
|
|
+ table1Map.put("se1", zse);
|
|
|
|
|
+ table1Map.put("je1", zje);
|
|
|
|
|
+ table1Map.put("jshj1", zjshj);
|
|
|
|
|
+ table1Map.put("jj", jj);
|
|
|
|
|
+ table1Map.put("zkl", zkl);
|
|
|
|
|
+ table1Map.put("zke", zke);
|
|
|
|
|
+ table1Map.put("xsjzj", xsjzj);
|
|
|
|
|
+ table1Map.put("zmzs", zmzs);
|
|
|
|
|
+ table1Map.put("yhrq", yhrq);
|
|
|
|
|
+
|
|
|
|
|
+ orderList.add(table1Map);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- }
|
|
|
|
|
|
|
|
|
|
-// 3. 删除数据库中存在但本次未传入的付款记录
|
|
|
|
|
- for (KdYdOrderPayment existing : existingPayments) {
|
|
|
|
|
- if (!incomingPaymentDetailIds.contains(existing.getDetailId())) {
|
|
|
|
|
- kdYdOrderPaymentMapper.deleteById(existing.getId());
|
|
|
|
|
- // 或软删除:existing.setSyncStatus("9"); updateById
|
|
|
|
|
|
|
+ // 处理付款明细
|
|
|
|
|
+ List<Map<String, Object>> OrderPayList = new ArrayList<>();
|
|
|
|
|
+ if (tableFieldPayment != null) {
|
|
|
|
|
+ for (int i = 0; i < tableFieldPayment.size(); i++) {
|
|
|
|
|
+ Map row = tableFieldPayment.get(i);
|
|
|
|
|
+ Map<String, Object> table2Map = new HashMap<>();
|
|
|
|
|
+ int detailId = i + 1;
|
|
|
|
|
+
|
|
|
|
|
+ String sfys = safeGetString(row, "radioField_mhiui6v7");
|
|
|
|
|
+ String gldh = safeGetString(row, "textField_mhiui6va");
|
|
|
|
|
+ BigDecimal ysbl = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6v6"));
|
|
|
|
|
+ BigDecimal ysje = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6v8"));
|
|
|
|
|
+ BigDecimal ssje = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6vb"));
|
|
|
|
|
+ LocalDateTime endTime = parseTimestamp(UtilMap.getString(row, "dateField_mhiui6v9"));
|
|
|
|
|
+
|
|
|
|
|
+ table2Map.put("detailId", detailId);
|
|
|
|
|
+ table2Map.put("sfys", sfys);
|
|
|
|
|
+ table2Map.put("gldh", gldh);
|
|
|
|
|
+ table2Map.put("ysbl", ysbl);
|
|
|
|
|
+ table2Map.put("ysje", ysje);
|
|
|
|
|
+ table2Map.put("ssje", ssje);
|
|
|
|
|
+ table2Map.put("endTime", endTime);
|
|
|
|
|
+
|
|
|
|
|
+ OrderPayList.add(table2Map);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 构建主表数据,映射到数据库表字段
|
|
|
|
|
+ Map<String, Object> orderData = new HashMap<>();
|
|
|
|
|
+
|
|
|
|
|
+ // 注意:这里需要将字段名映射到数据库表字段名
|
|
|
|
|
+ // 示例映射,实际需要根据数据库表结构调整
|
|
|
|
|
+ orderData.put("djlx", djlx); // 单据类型
|
|
|
|
|
+ orderData.put("djbh", djbh); // 单据编号
|
|
|
|
|
+ orderData.put("khmc", khmc); // 客户名称
|
|
|
|
|
+ orderData.put("rq", rq); // 日期
|
|
|
|
|
+ orderData.put("khxypj", khxypj); // 客户信用评级
|
|
|
|
|
+ orderData.put("ywlx", ywlx); // 业务类型
|
|
|
|
|
+ orderData.put("xslx", xslx); // 销售类型
|
|
|
|
|
+ orderData.put("bzq", bzq); // 保质期
|
|
|
|
|
+ orderData.put("xsy", xsy); // 销售员
|
|
|
|
|
+ orderData.put("xsbm", xsbm); // 销售部门
|
|
|
|
|
+ orderData.put("bz", bz); // 备注
|
|
|
|
|
+ orderData.put("jsbb", jsbb); // 结算币别
|
|
|
|
|
+ orderData.put("sktj", sktj); // 收款条件
|
|
|
|
|
+ orderData.put("zdzke", zdzke); // 整单折扣额
|
|
|
|
|
+ orderData.put("se", se); // 税额
|
|
|
|
|
+ orderData.put("je", je); // 金额
|
|
|
|
|
+ orderData.put("jshj", jshj); // 价税合计
|
|
|
|
|
+ orderData.put("sfhs", sfhs); // 是否含税
|
|
|
|
|
+ orderData.put("jws", jws); // 价位税
|
|
|
|
|
+
|
|
|
|
|
+ // 明细数据(需要根据实际数据库设计确定存储方式)
|
|
|
|
|
+ // 如果明细是单独的表,可能需要单独处理
|
|
|
|
|
+ orderData.put("OrderDetailList", orderList); // 订单明细列表
|
|
|
|
|
+ orderData.put("PaymentDetailList", OrderPayList); // 付款明细列表
|
|
|
|
|
+
|
|
|
|
|
+ Map<String, String> headers = new HashMap<>();
|
|
|
|
|
+ headers.put("Content-Type", "application/x-www-form-urlencoded");
|
|
|
|
|
+
|
|
|
|
|
+ result.put("data", orderData);
|
|
|
|
|
+// 将result转换为JSON字符串
|
|
|
|
|
+ String jsonStr = JSON.toJSONString(result);
|
|
|
|
|
+// 构建form参数
|
|
|
|
|
+ Map<String, Object> formParams = new HashMap<>();
|
|
|
|
|
+ formParams.put("jsons", jsonStr);
|
|
|
|
|
+// 发送请求
|
|
|
|
|
+ HttpResponse response = null;
|
|
|
|
|
+ if (actionType == "add") {
|
|
|
|
|
+ response = HttpRequest.post("http://113.45.187.194:70/xk/dyzn/WsBasedyzn.asmx/hgdjydtbxsdd")
|
|
|
|
|
+ .headerMap(headers, true)
|
|
|
|
|
+ .form(formParams)
|
|
|
|
|
+ .timeout(30000) // 30秒超时
|
|
|
|
|
+ .execute();
|
|
|
|
|
+ } else {
|
|
|
|
|
+ response = HttpRequest.post("http://113.45.187.194:70/xk/dyzn/WsBasedyzn.asmx/hgdjydtbupdatexsdd")
|
|
|
|
|
+ .headerMap(headers, true)
|
|
|
|
|
+ .form(formParams)
|
|
|
|
|
+ .timeout(30000) // 30秒超时
|
|
|
|
|
+ .execute();
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ String responseBody = response.body();
|
|
|
|
|
+ try {
|
|
|
|
|
+ // 一行代码提取
|
|
|
|
|
+ String jdbh = JSON.parseArray(responseBody)
|
|
|
|
|
+ .getJSONObject(0)
|
|
|
|
|
+ .getJSONObject("data")
|
|
|
|
|
+ .getString("djbh");
|
|
|
|
|
+ String msg = JSON.parseArray(responseBody)
|
|
|
|
|
+ .getJSONObject(0)
|
|
|
|
|
+ .getString("msg");
|
|
|
|
|
+ ydClient.operateData(
|
|
|
|
|
+ YDParam.builder()
|
|
|
|
|
+ .formInstanceId(formInstId)
|
|
|
|
|
+ .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textareaField_mkxqgrvq, textField_mjs6fuwo", msg, jdbh)))
|
|
|
|
|
+ .useLatestVersion(true).build(),
|
|
|
|
|
+ YDConf.FORM_OPERATION.update);
|
|
|
|
|
+
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ System.out.println("解析JSON失败: " + e.getMessage());
|
|
|
}
|
|
}
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ // 异常处理
|
|
|
|
|
+ result.put("table", "KD_YD_SALE_ORDER");
|
|
|
|
|
+ result.put("action", "error");
|
|
|
|
|
+ result.put("data", new HashMap<String, Object>() {{
|
|
|
|
|
+ put("errorMsg", "操作失败:" + e.getMessage());
|
|
|
|
|
+ }});
|
|
|
|
|
+ // 可以添加日志记录
|
|
|
|
|
+ // log.error("insertkdYdOrder error", e);
|
|
|
}
|
|
}
|
|
|
-// ydClient.operateData(
|
|
|
|
|
-// YDParam.builder()
|
|
|
|
|
-// .formInstanceId(formInstId)
|
|
|
|
|
-// .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mgrmn66f", id)))
|
|
|
|
|
-// .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);
|
|
|
|
|
|
|
|
|
|
|
|
+ return result;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -454,7 +452,7 @@ public class KdYdOrderServiceImpl extends ServiceImpl<KdYdOrderMapper, KdYdOrder
|
|
|
String khsx = "";
|
|
String khsx = "";
|
|
|
|
|
|
|
|
// 1. 设置客户属性(单独判断)
|
|
// 1. 设置客户属性(单独判断)
|
|
|
- if(totalAmount >= 75000 && sfToDdDays <= 180){
|
|
|
|
|
|
|
+ if (totalAmount >= 75000 && sfToDdDays <= 180) {
|
|
|
khsx = "自行开发";
|
|
khsx = "自行开发";
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -549,8 +547,9 @@ public class KdYdOrderServiceImpl extends ServiceImpl<KdYdOrderMapper, KdYdOrder
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 计算时间戳:在基础时间戳上添加天数
|
|
* 计算时间戳:在基础时间戳上添加天数
|
|
|
|
|
+ *
|
|
|
* @param baseTimestamp 基础时间戳(毫秒)
|
|
* @param baseTimestamp 基础时间戳(毫秒)
|
|
|
- * @param days 要添加的天数
|
|
|
|
|
|
|
+ * @param days 要添加的天数
|
|
|
* @return 计算后的时间戳(毫秒)
|
|
* @return 计算后的时间戳(毫秒)
|
|
|
*/
|
|
*/
|
|
|
private long calculateTimestamp(long baseTimestamp, int days) {
|
|
private long calculateTimestamp(long baseTimestamp, int days) {
|