|
|
@@ -1,5 +1,6 @@
|
|
|
package com.malk.fenggefushi.service.Impl;
|
|
|
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
@@ -1007,7 +1008,7 @@ public class HeiHuOrderServiceImpl implements HeiHuOrderService {
|
|
|
header.put("X-AUTH", HeiHuAccessToken().getData().toString());
|
|
|
header.put("Content-Type", "application/json");
|
|
|
String targetValue = "合同确认,提交审批";
|
|
|
- String targetValue1 = "合同修改,修改审批";
|
|
|
+// String targetValue1 = "合同修改,修改审批";
|
|
|
Map<String, List<String>> purchaserOrderCodes = new HashMap<>();
|
|
|
|
|
|
int pageNum = 1;
|
|
|
@@ -1043,7 +1044,8 @@ public class HeiHuOrderServiceImpl implements HeiHuOrderService {
|
|
|
List<Map<String, Object>> customFieldValues = (List<Map<String, Object>>) item.get("customFieldValues");
|
|
|
if (customFieldValues != null) {
|
|
|
for (Map<String, Object> field : customFieldValues) {
|
|
|
- if (targetValue.equals(field.get("value") ) || targetValue1.equals(field.get("value"))) {
|
|
|
+// if (targetValue.equals(field.get("value") ) || targetValue1.equals(field.get("value"))) {
|
|
|
+ if (targetValue.equals(field.get("value"))) {
|
|
|
hasTargetStatus = true;
|
|
|
break;
|
|
|
}
|
|
|
@@ -1401,7 +1403,482 @@ public class HeiHuOrderServiceImpl implements HeiHuOrderService {
|
|
|
|
|
|
return null;
|
|
|
}
|
|
|
+ @Override
|
|
|
+ public McR purchaseUpdateSchedule() throws JacksonException {
|
|
|
+ HashMap header = new HashMap();
|
|
|
+ header.put("X-AUTH", HeiHuAccessToken().getData().toString());
|
|
|
+ header.put("Content-Type", "application/json");
|
|
|
+ String targetValue = "合同修改,修改审批";
|
|
|
+ Map<String, List<String>> purchaserOrderCodes = new HashMap<>();
|
|
|
+
|
|
|
+ int pageNum = 1;
|
|
|
+ int pageSize = 100;
|
|
|
+ boolean hasMoreData = true;
|
|
|
+ boolean isUpdate = false;
|
|
|
+
|
|
|
+ while (hasMoreData) {
|
|
|
+ HashMap body = new HashMap();
|
|
|
+ Map<String, Integer> page = new HashMap<>();
|
|
|
+ page.put("pageNum", pageNum);
|
|
|
+ page.put("pageSize", pageSize);
|
|
|
+ List<Integer> status = Arrays.asList(1);
|
|
|
+ body.put("page", page);
|
|
|
+ body.put("status", status);
|
|
|
+
|
|
|
+ String doPost = UtilHttp.doPost("https://liteweb.blacklake.cn/api/dytin/external/purchaseOrder/queryList2", header, null, body);//查询采购订单
|
|
|
+
|
|
|
+ ObjectMapper mapper = new ObjectMapper();
|
|
|
+ Map<String, Object> response = mapper.readValue(doPost, Map.class);
|
|
|
+
|
|
|
+ if (!"01000000".equals(response.get("code"))) {
|
|
|
+ System.out.println("请求失败: " + response.get("msg"));
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ List<Map<String, Object>> dataList = (List<Map<String, Object>>) response.get("data");
|
|
|
+ if (dataList != null) {
|
|
|
+ for (Map<String, Object> item : dataList) {
|
|
|
+ String purchaserName = (String) item.get("purchaserName");
|
|
|
+ if (purchaserName == null) purchaserName = "未知";
|
|
|
+
|
|
|
+ boolean hasTargetStatus = false;
|
|
|
+ List<Map<String, Object>> customFieldValues = (List<Map<String, Object>>) item.get("customFieldValues");
|
|
|
+ if (customFieldValues != null) {
|
|
|
+ for (Map<String, Object> field : customFieldValues) {
|
|
|
+ if (targetValue.equals(field.get("value"))) {
|
|
|
+ hasTargetStatus = true;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (hasTargetStatus) {
|
|
|
+ String orderCode = (String) item.get("orderCode");
|
|
|
+ if (orderCode != null) {
|
|
|
+ purchaserOrderCodes.computeIfAbsent(purchaserName, k -> new ArrayList<>()).add(orderCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ hasMoreData = dataList.size() >= pageSize;
|
|
|
+ } else {
|
|
|
+ hasMoreData = false;
|
|
|
+ }
|
|
|
+
|
|
|
+ pageNum++;
|
|
|
+
|
|
|
+ try {
|
|
|
+ Thread.sleep(200);
|
|
|
+ } catch (InterruptedException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 输出所有采购员的待审批订单
|
|
|
+ System.out.println("========== 所有采购员的待审批订单统计 ==========");
|
|
|
+
|
|
|
+ if (purchaserOrderCodes.isEmpty()) {
|
|
|
+ System.out.println("没有找到钉钉审批状态为'" + targetValue + "'的订单");
|
|
|
+ } else {
|
|
|
+ int totalPurchasers = purchaserOrderCodes.size();
|
|
|
+ int totalOrders = purchaserOrderCodes.values().stream().mapToInt(List::size).sum();
|
|
|
+
|
|
|
+ System.out.println("共找到 " + totalOrders + " 个待审批订单");
|
|
|
+ System.out.println("涉及 " + totalPurchasers + " 位采购员");
|
|
|
+ System.out.println();
|
|
|
+
|
|
|
+ // 输出每个采购员的情况
|
|
|
+ for (Map.Entry<String, List<String>> entry : purchaserOrderCodes.entrySet()) {
|
|
|
+ String purchaserName = entry.getKey();
|
|
|
+ List<String> orderCodes = entry.getValue();
|
|
|
+ int orderCount = orderCodes.size();
|
|
|
+
|
|
|
+ System.out.println("采购员: " + purchaserName);
|
|
|
+ System.out.println("待审批订单数量: " + orderCount);
|
|
|
+
|
|
|
+ if (orderCount > 1) {
|
|
|
+ System.out.println("⚠️ 注意:该采购员有 " + orderCount + " 个待审批订单");
|
|
|
+ }
|
|
|
+
|
|
|
+ System.out.println("订单编号: " + String.join(", ", orderCodes));
|
|
|
+ System.out.println();
|
|
|
+ }
|
|
|
+
|
|
|
+ // 按订单数量排序输出
|
|
|
+ System.out.println("========== 按待审批订单数量排序 ==========");
|
|
|
+ purchaserOrderCodes.entrySet().stream()
|
|
|
+ .sorted((e1, e2) -> Integer.compare(e2.getValue().size(), e1.getValue().size()))
|
|
|
+ .forEach(entry -> {
|
|
|
+ String purchaserName = entry.getKey();
|
|
|
+ List<String> orderCodes = entry.getValue();
|
|
|
+ System.out.println(purchaserName + " (" + orderCodes.size() + "个): " +
|
|
|
+ String.join(", ", orderCodes));
|
|
|
+
|
|
|
+ // ========== 修改点1:声明两个列表分别存储不同毛利率的订单数据 ==========
|
|
|
+ // 针对同一个采购员,遍历下面的订单编号
|
|
|
+ System.out.println("开始处理采购员 " + purchaserName + " 的 " + orderCodes.size() + " 个待审批订单");
|
|
|
+
|
|
|
+ // 高毛利率表单数据 (mlv >= 0.15)
|
|
|
+ HashMap formdataHigh = new HashMap();
|
|
|
+ List<Map<String,String>> tabledataHigh = new ArrayList();
|
|
|
+
|
|
|
+ // 低毛利率表单数据 (mlv < 0.15)
|
|
|
+ HashMap formdataLow = new HashMap();
|
|
|
+ List<Map<String,String>> tabledataLow = new ArrayList();
|
|
|
+
|
|
|
+ // ========== 修改点2:为每个订单创建临时存储列表 ==========
|
|
|
+ // 用于暂存每个订单的明细数据,等计算出毛利率后再决定添加到哪个列表
|
|
|
+ Map<String, List<Map<String, String>>> tempOrderDataMap = new HashMap<>();
|
|
|
+ // 用于存储每个订单的汇总数据,用于计算毛利率
|
|
|
+ Map<String, Map<String, Double>> orderSummaryForMlv = new HashMap<>();
|
|
|
+ List<String> oldHighIds = new ArrayList<>();
|
|
|
+ List<String> oldLowIds = new ArrayList<>();
|
|
|
+
|
|
|
+ for (String orderCode : orderCodes) {
|
|
|
+ System.out.println("正在处理订单: " + orderCode);
|
|
|
+
|
|
|
+ // ========== 修改点3:为当前订单创建临时数据存储 ==========
|
|
|
+ List<Map<String, String>> currentOrderRows = new ArrayList<>();
|
|
|
+ double orderTotalSalesAmount = 0.0;
|
|
|
+ double orderTotalPurchaseAmount = 0.0;
|
|
|
+ double orderTotalFlygcb = 0.0;
|
|
|
+
|
|
|
+ //todo:查询订单的销售订单 | 客户 销售订单号 款式 产品描述 颜色 | 数量 销售单价 销售金额 | 币别 美金汇率 辅料预估成本 销售总金额
|
|
|
+ String customerName = "",orderNumber ="",styleNumber ="",productDescription = "",color = "";
|
|
|
+ Double number,unitPrice,salesAmount;
|
|
|
+ String currency = ""; Double USDrate = 0.00; Double flygcb = 0.00; Double saletotalAmount = 0.00;
|
|
|
+ Double estimatedPrice = 0.00;//辅料预估单价
|
|
|
+
|
|
|
+ HashMap body = new HashMap();
|
|
|
+ body.put("orderCode",orderCode);//订单编号
|
|
|
+ String jsonString = UtilHttp.doPost("https://liteweb.blacklake.cn/api/dytin/external/purchaseOrder/queryList2", header, null, body);
|
|
|
+ //todo:查询采购订单 生产工厂(供应商)
|
|
|
+ String shortName = "";
|
|
|
+ JSONArray dataArray = JSONObject.parseObject(jsonString).getJSONArray("data");
|
|
|
+ for (int i=0;i<dataArray.size();i++) {
|
|
|
+ JSONObject data = dataArray.getJSONObject(i);
|
|
|
+ shortName = data.getString("shortName");//供应商:shortName
|
|
|
+ }
|
|
|
+ JSONArray products = JSONObject.parseObject(jsonString).getJSONArray("data").getJSONObject(0).getJSONArray("purchaseSubOrderVOS");
|
|
|
+ ObjectMapper objectMapper = new ObjectMapper();
|
|
|
+ JsonNode rootNode = null;
|
|
|
+ try {
|
|
|
+ rootNode = objectMapper.readTree(jsonString);
|
|
|
+ } catch (JsonProcessingException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ JsonNode dataNode = rootNode.get("data");
|
|
|
+ if(dataNode != null && dataNode.isArray()){
|
|
|
+ for(JsonNode item : dataNode){
|
|
|
+ JsonNode orderNoNode = item.get("orderCode");
|
|
|
+ JsonNode saleOrders = item.get("relationSaleOrders");
|
|
|
+ if(saleOrders != null && saleOrders.isArray() && saleOrders.size() > 0){
|
|
|
+ orderNumber = saleOrders.get(0).asText();//销售订单号
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ HashMap body_A = new HashMap();
|
|
|
+ body_A.put("orderNo",orderNumber);
|
|
|
+ String jsonString2 = UtilHttp.doPost("https://liteweb.blacklake.cn/api/dytin/external/saleOrder/queryList2", header, null, body_A);//todo:查询销售订单,获取客户、订单号、款号、产品描述、颜色、数量、销售单价、销售金额、币别
|
|
|
+ JSONArray array = JSONObject.parseObject(jsonString2).getJSONArray("data");//主表数据
|
|
|
+ for(int i=0;i<array.size();i++){
|
|
|
+ JSONObject data = array.getJSONObject(i);
|
|
|
+ customerName = data.getString("customerCode");//客户
|
|
|
+ }
|
|
|
+ ObjectMapper objectMapper2 = new ObjectMapper();
|
|
|
+ JsonNode dataNode2 = null;//主表数据
|
|
|
+ try {
|
|
|
+ dataNode2 = objectMapper2.readTree(jsonString2).get("data");
|
|
|
+ } catch (JsonProcessingException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ for (JsonNode item : dataNode2){
|
|
|
+ JsonNode customFieldValues = item.get("customFieldValues");
|
|
|
+ for (JsonNode field : customFieldValues){
|
|
|
+ JsonNode fieldIdNode = field.get("fieldId");
|
|
|
+ if(fieldIdNode != null && fieldIdNode.asInt() == 161769){
|
|
|
+ JsonNode valueNode = field.get("value");
|
|
|
+ if(valueNode != null){
|
|
|
+ estimatedPrice = valueNode.asDouble();//辅料预估单价
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ JSONArray products_A = JSONObject.parseObject(jsonString2).getJSONArray("data").getJSONObject(0).getJSONArray("saleManageOrderDetailRowApiVOList");//销售订单明细数据
|
|
|
+
|
|
|
+ if(products_A != null) {
|
|
|
+ for (int i = 0; i < products_A.size(); i++) {
|
|
|
+ JSONObject detail = products_A.getJSONObject(i);
|
|
|
+ HashMap row = new HashMap();
|
|
|
+ row.put("textField_mm2t71jm",orderCode);//todo:采购订单单号
|
|
|
+ row.put("textField_ml6g7k5e", customerName);//todo:客户
|
|
|
+ row.put("textField_ml6g7k5f", orderNumber);//todo:订单号
|
|
|
+
|
|
|
+ styleNumber = detail.getString("productCode");//款号
|
|
|
+ row.put("textField_ml7c3yhq", styleNumber);//todo:款号
|
|
|
+
|
|
|
+ productDescription = detail.getString("productName");//产品描述
|
|
|
+ row.put("textField_ml7c3yhr", productDescription);//todo:产品描述
|
|
|
+
|
|
|
+ JSONArray array1 = detail.getJSONArray("customFieldValues");
|
|
|
+ color = array1.stream()
|
|
|
+ .map(obj -> (JSONObject) obj)
|
|
|
+ .filter(item -> item.getIntValue("fieldId") == 82259)
|
|
|
+ .map(item -> item.getString("value"))
|
|
|
+ .findFirst()
|
|
|
+ .orElse(null);
|
|
|
+ ArrayList colorList = new ArrayList();
|
|
|
+ colorList.add(color);
|
|
|
+ String color_AAA = null;
|
|
|
+ try {
|
|
|
+ color_AAA = getProductColor(colorList);
|
|
|
+ } catch (JacksonException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ row.put("textField_ml7c3yhs", color_AAA);//todo:颜色
|
|
|
+
|
|
|
+ number = detail.getDoubleValue("qty");//数量
|
|
|
+ row.put("numberField_ml7c3yht", number);//todo:数量
|
|
|
+
|
|
|
+ unitPrice = detail.getDoubleValue("unitPrice");//销售单价
|
|
|
+ row.put("numberField_ml7c3yhu", unitPrice);//todo:销售单价
|
|
|
+
|
|
|
+ salesAmount = number * unitPrice;//销售金额
|
|
|
+ row.put("numberField_ml7c3yhv", salesAmount);//todo:销售金额
|
|
|
+ String customFieldValues = detail.getString("customFieldValues");
|
|
|
+ ObjectMapper mapper = new ObjectMapper();
|
|
|
+ JsonNode jsonarray = null;
|
|
|
+ try {
|
|
|
+ jsonarray = mapper.readTree(customFieldValues);
|
|
|
+ } catch (JsonProcessingException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+ for (JsonNode node : jsonarray) {
|
|
|
+ if (node.get("fieldId").asInt() == 47919) {
|
|
|
+ currency = node.get("value").asText();
|
|
|
+ } else if (node.get("fieldId").asInt() == 165251) {
|
|
|
+ USDrate = node.get("value").asDouble();
|
|
|
+
|
|
|
+ } else if (node.get("fieldId").asInt() == 161783) {
|
|
|
+ flygcb = node.get("value").asDouble();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ row.put("textField_ml7c3yhw", currency);//todo:币别
|
|
|
+ row.put("numberField_ml86221y", USDrate);//todo:美金汇率
|
|
|
+ row.put("numberField_ml86221z", flygcb);//todo:辅料预估成本
|
|
|
+ if(currency.equals("USD")){
|
|
|
+ saletotalAmount = salesAmount * USDrate;
|
|
|
+ }else {
|
|
|
+ saletotalAmount = salesAmount;
|
|
|
+ }
|
|
|
+ row.put("numberField_ml862220",saletotalAmount);
|
|
|
+ //下面是采购订单的明细数据
|
|
|
+ row.put("textField_ml7c3yhx",shortName);//todo:生产工厂
|
|
|
+ for(int j=0;j<products.size();j++){
|
|
|
+ if(styleNumber.equals(products.getJSONObject(j).getString("productCode"))){
|
|
|
+ //找到对应的采购一行数据
|
|
|
+ row.put("numberField_ml7c3yhy",products.getJSONObject(j).getDouble("purchasePrice"));//todo:采购单价
|
|
|
+ row.put("numberField_ml7c3yhz",products.getJSONObject(j).getDouble("purchaseNum"));//todo:采购数量
|
|
|
+ row.put("numberField_ml7c3yi0",products.getJSONObject(j).getDouble("purchasePrice") * products.getJSONObject(j).getDouble("purchaseNum"));//todo:采购金额
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // ========== 修改点4:将当前行转换为Map<String,String>并暂存 ==========
|
|
|
+ Map<String, String> rowMap = new HashMap<>();
|
|
|
+ for (Object key : row.keySet()) {
|
|
|
+ Object value = row.get(key);
|
|
|
+ rowMap.put(key.toString(), value != null ? value.toString() : "");
|
|
|
+ }
|
|
|
+ currentOrderRows.add(rowMap);
|
|
|
+
|
|
|
+ // ========== 修改点5:累加当前订单的汇总数据用于计算毛利率 ==========
|
|
|
+ orderTotalSalesAmount += saletotalAmount;
|
|
|
+ orderTotalPurchaseAmount += (Double)row.get("numberField_ml7c3yi0");
|
|
|
+ orderTotalFlygcb += flygcb;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // ========== 修改点6:计算当前订单的毛利率 ==========
|
|
|
+ double mlv = 0.0;
|
|
|
+ if (orderTotalSalesAmount > 0) {
|
|
|
+ mlv = (orderTotalSalesAmount - orderTotalPurchaseAmount - orderTotalFlygcb) / orderTotalSalesAmount;
|
|
|
+ }
|
|
|
+
|
|
|
+ System.out.println("订单 " + orderCode + " 毛利率: " + String.format("%.2f%%", mlv * 100));
|
|
|
+
|
|
|
+ // ========== 修改点7:根据毛利率决定添加到哪个列表 ==========
|
|
|
+ if (mlv >= 0.15) {
|
|
|
+ // 高毛利率订单
|
|
|
+ tabledataHigh.addAll(currentOrderRows);
|
|
|
+ oldHighIds.add(orderCode);
|
|
|
+ System.out.println("订单 " + orderCode + " 归类到高毛利率审批(>=15%)");
|
|
|
+ } else {
|
|
|
+ // 低毛利率订单
|
|
|
+ tabledataLow.addAll(currentOrderRows);
|
|
|
+ oldLowIds.add(orderCode);
|
|
|
+ System.out.println("订单 " + orderCode + " 归类到低毛利率审批(<15%)");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // ========== 修改点8:分别处理高低毛利率的审批 ==========
|
|
|
+
|
|
|
+ // 处理高毛利率的审批 (mlv >= 0.15)
|
|
|
+ if (!tabledataHigh.isEmpty()) {
|
|
|
+ System.out.println("\n========== 开始处理高毛利率审批(>=15%),共 " + tabledataHigh.size() + " 条明细 ==========");
|
|
|
+ List<Map<String, Object>> oldList = new ArrayList<>();
|
|
|
+ oldHighIds.forEach(h->{
|
|
|
+ List<Map> dataList = ydService.queryFormData_all(YDParam.builder()
|
|
|
+ .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
|
|
|
+ .formUuid("FORM-278D56A5065641F8AC95BCA0A8CE8447D8QY")
|
|
|
+ .searchFieldJson(JSON.toJSONString(UtilMap.map("textField_mmx9gyct", h)))
|
|
|
+ .build());
|
|
|
+ if (ObjectUtil.isNotNull(dataList) && dataList.size()>0){
|
|
|
+ List<Map> sonList = ydService.queryDetails(YDParam.builder()
|
|
|
+ .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
|
|
|
+ .formInstanceId(UtilMap.getString(dataList.get(0),"textField_mmx9gycu"))
|
|
|
+ .formUuid("FORM-3A54B12BE3D241218A75242B935F2987YWV2")
|
|
|
+ .tableFieldId("tableField_ml6g7k5d")
|
|
|
+ .build());
|
|
|
+ if (ObjectUtil.isNotNull(sonList) && sonList.size() > 0){
|
|
|
+ sonList.forEach(s->{
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ TABLEFIELD_ENUM.forEach((k,v)->{
|
|
|
+ map.put(v,UtilMap.getString(s,k));
|
|
|
+ });
|
|
|
+ oldList.add(map);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+ //组装数据塞到采购明细表
|
|
|
+ formdataHigh.put("tableField_ml6g7k5d", tabledataHigh);
|
|
|
+ formdataHigh.put("tableField_mmx6gata", oldList);
|
|
|
+
|
|
|
+ //组装数据塞到采购审批单号明细
|
|
|
+ List<Map<String, String>> orderSummaryListHigh = calculateOrderSummary(tabledataHigh);
|
|
|
+ formdataHigh.put("tableField_ml7ch2pj", orderSummaryListHigh);
|
|
|
+
|
|
|
+ //数值统计毛利率
|
|
|
+ int szHigh = 0;
|
|
|
+ for (Map map : orderSummaryListHigh) {
|
|
|
+ Object numberFieldMm2t71jo = map.get("numberField_mm2t71jo");
|
|
|
+ log.info((String) numberFieldMm2t71jo);
|
|
|
+ szHigh += Integer.parseInt((String) numberFieldMm2t71jo);
|
|
|
+ }
|
|
|
+ formdataHigh.put("numberField_mm2t71jp", szHigh);
|
|
|
+
|
|
|
+ /*发起流程 - 高毛利率审批*/
|
|
|
+ String userId = getDDToken(purchaserName);
|
|
|
+ ydClient.operateData(YDParam.builder()
|
|
|
+ .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
|
|
|
+ .formUuid("FORM-3A54B12BE3D241218A75242B935F2987YWV2") // 高毛利率使用原表单
|
|
|
+ .userId(userId)
|
|
|
+ .formDataJson(JSON.toJSONString(formdataHigh))
|
|
|
+ .build(), YDConf.FORM_OPERATION.start).toString();
|
|
|
+
|
|
|
+ /*修改采购订单为审批中*/
|
|
|
+ for (Map map : orderSummaryListHigh) {
|
|
|
+ String textFieldMl7ch2pk = (String) map.get("textField_ml7ch2pk");
|
|
|
+ callback(textFieldMl7ch2pk);
|
|
|
+ }
|
|
|
+
|
|
|
+ System.out.println("高毛利率审批流程发起完成");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 处理低毛利率的审批 (mlv < 0.15)
|
|
|
+ if (!tabledataLow.isEmpty()) {
|
|
|
+ System.out.println("\n========== 开始处理低毛利率审批(<15%),共 " + tabledataLow.size() + " 条明细 ==========");
|
|
|
+ List<Map<String, Object>> oldList = new ArrayList<>();
|
|
|
+ oldLowIds.forEach(h->{
|
|
|
+ List<Map> dataList = ydService.queryFormData_all(YDParam.builder()
|
|
|
+ .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
|
|
|
+ .formUuid("FORM-278D56A5065641F8AC95BCA0A8CE8447D8QY")
|
|
|
+ .searchFieldJson(JSON.toJSONString(UtilMap.map("textField_mmx9gyct", h)))
|
|
|
+ .build());
|
|
|
+ if (ObjectUtil.isNotNull(dataList) && dataList.size()>0){
|
|
|
+ List<Map> sonList = ydService.queryDetails(YDParam.builder()
|
|
|
+ .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
|
|
|
+ .formInstanceId(UtilMap.getString(dataList.get(0),"textField_mmx9gycu"))
|
|
|
+ .formUuid("FORM-3A54B12BE3D241218A75242B935F2987YWV2")
|
|
|
+ .tableFieldId("tableField_ml6g7k5d")
|
|
|
+ .build());
|
|
|
+ if (ObjectUtil.isNotNull(sonList) && sonList.size() > 0){
|
|
|
+ sonList.forEach(s->{
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ TABLEFIELD_ENUM.forEach((k,v)->{
|
|
|
+ map.put(v,UtilMap.getString(s,k));
|
|
|
+ });
|
|
|
+ oldList.add(map);
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+ //组装数据塞到采购明细表
|
|
|
+ formdataHigh.put("tableField_mmx6gata", oldList);
|
|
|
+ //组装数据塞到采购明细表
|
|
|
+ formdataLow.put("tableField_ml6g7k5d", tabledataLow);
|
|
|
+
|
|
|
+ //组装数据塞到采购审批单号明细
|
|
|
+ List<Map<String, String>> orderSummaryListLow = calculateOrderSummary(tabledataLow);
|
|
|
+ formdataLow.put("tableField_ml7ch2pj", orderSummaryListLow);
|
|
|
+
|
|
|
+ //数值统计毛利率
|
|
|
+ int szLow = 0;
|
|
|
+ for (Map map : orderSummaryListLow) {
|
|
|
+ Object numberFieldMm2t71jo = map.get("numberField_mm2t71jo");
|
|
|
+ log.info((String) numberFieldMm2t71jo);
|
|
|
+ szLow += Integer.parseInt((String) numberFieldMm2t71jo);
|
|
|
+ }
|
|
|
+ formdataLow.put("numberField_mm2t71jp", szLow);
|
|
|
+
|
|
|
+ /*发起流程 - 低毛利率审批*/
|
|
|
+ String userId = getDDToken(purchaserName);
|
|
|
+ // ========== 修改点9:如果低毛利率需要不同表单,可以在这里修改formUuid ==========
|
|
|
+ ydClient.operateData(YDParam.builder()
|
|
|
+ .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
|
|
|
+ .formUuid("FORM-3A54B12BE3D241218A75242B935F2987YWV2") // 如果需要不同流程,替换这里的UUID
|
|
|
+ .userId(userId)
|
|
|
+ .formDataJson(JSON.toJSONString(formdataLow))
|
|
|
+ .build(), YDConf.FORM_OPERATION.start).toString();
|
|
|
|
|
|
+ /*修改采购订单为审批中*/
|
|
|
+ for (Map map : orderSummaryListLow) {
|
|
|
+ String textFieldMl7ch2pk = (String) map.get("textField_ml7ch2pk");
|
|
|
+ callback(textFieldMl7ch2pk);
|
|
|
+ }
|
|
|
+
|
|
|
+ System.out.println("低毛利率审批流程发起完成");
|
|
|
+ }
|
|
|
+
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ private static final Map<String,String> TABLEFIELD_ENUM =new HashMap<>();
|
|
|
+ static {
|
|
|
+ TABLEFIELD_ENUM.put("textField_mm2t71jm","textField_mmx6gast");
|
|
|
+ TABLEFIELD_ENUM.put("textField_ml6g7k5e","textField_mmx6gasu");
|
|
|
+ TABLEFIELD_ENUM.put("textField_ml6g7k5f","textField_mmx6gasv");
|
|
|
+ TABLEFIELD_ENUM.put("textField_ml7c3yhq","textField_mmx6gasw");
|
|
|
+ TABLEFIELD_ENUM.put("textField_ml7c3yhr","textField_mmx6gasx");
|
|
|
+ TABLEFIELD_ENUM.put("textField_ml7c3yhs","textField_mmx6gasy");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml7c3yht","numberField_mmx6gasz");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml7c3yhu","numberField_mmx6gat0");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml7c3yhv","numberField_mmx6gat1");
|
|
|
+ TABLEFIELD_ENUM.put("textField_ml7c3yhw","textField_mmx6gat2");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml86221y","numberField_mmx6gat3");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml86221z","numberField_mmx6gat4");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml862220","numberField_mmx6gat5");
|
|
|
+ TABLEFIELD_ENUM.put("textField_ml7c3yhx","textField_mmx6gat6");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml7c3yhy","numberField_mmx6gat7");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml7c3yhz","numberField_mmx6gat8");
|
|
|
+ TABLEFIELD_ENUM.put("numberField_ml7c3yi0","numberField_mmx6gat9");
|
|
|
+ }
|
|
|
/**
|
|
|
* 根据orderCode对tabledata进行分类求和
|
|
|
* @param tableData 原始明细数据
|