彪马规则是这样的：二代按销售额提取，每年2个月月租；（单店要利润率大于20%；否则不计提）销售员按销售利润提取，每年 20%；

com.awspaas.user.apps.donenow_ctt/src/com/awspaas/user/apps/donenow_ctt/controller/contractCreateController.java

@@ -569,4 +569,22 @@ public class contractCreateController {
         return ResponseObject.newOkResponse();
     }
 
+
+    /**
+     * 批量生产合同服务周期
+     * @return
+     */
+    @Mapping(value = "com.awspaas.user.apps.donenow_ctt.contract_service_exec", session = false, noSessionEvaluate = "无安全隐患", noSessionReason = "批量生产")
+    public String contractServicExec() {
+        List<RowMap> services = DBSql.getMaps("SELECT CONTRACT_ID,GROUP_CONCAT(ID) IDS FROM bo_eu_dnctt_contract_service WHERE CONTRACT_ID in (SELECT ID FROM BO_EU_DNCTT_CONTRACT WHERE FRAMEWORK='7c2841c3-8f51-4dea-a6ea-984d9b9c3574' AND NO NOT LIKE '%old%' ) GROUP BY CONTRACT_ID");
+        UserContext uc = UserContext.fromUID("admin");
+        for (RowMap service : services) {
+            String contractId = service.getString("CONTRACT_ID");
+            String serviceIds = service.getString("IDS");
+            servicePeriod(uc, contractId, serviceIds);
+            serviceCost(uc, contractId, serviceIds);
+        }
+        return "ok";
+    }
+
 }

com.awspaas.user.apps.donenow_ctt/src/com/awspaas/user/apps/donenow_ctt/event/contractCreateFormAfterSave.java

@@ -8,6 +8,7 @@ import com.actionsoft.bpms.commons.database.RowMap;
 import com.actionsoft.bpms.util.DBSql;
 import com.actionsoft.sdk.local.SDK;
 import com.awspaas.user.apps.donenow_ctt.service.contractService;
+import org.apache.commons.lang3.StringUtils;
 
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -122,6 +123,25 @@ public class contractCreateFormAfterSave extends ExecuteListener {
 
 
              */
+
+            String CONTRACT_ID = DBSql.getString("select CONTRACT_ID from BO_EU_DNCTT_CONTRACT_SERVICE where BINDID=?", new Object[]{bindid});
+            try {
+                //新增服务后，根据服务的月成本、月收入 计算月利润
+                String profit = DBSql.getString("SELECT (SUM(UNIT_PRICE_MONTH)-SUM(UNIT_COST_MONTH))/SUM(UNIT_COST_MONTH) FROM BO_EU_DNCTT_CONTRACT_SERVICE WHERE CONTRACT_ID=? ", new Object[]{CONTRACT_ID});
+                RowMap contractBO = DBSql.getMap("select MINIMUM_PROFIT_MARGIN,ALLOW_COMMISSION_PAYMENT from BO_EU_DNCTT_CONTRACT where ID=?", new Object[]{CONTRACT_ID});
+                Double profitMargin = contractBO.getDouble("MINIMUM_PROFIT_MARGIN");
+                int ALLOW_COMMISSION_PAYMENT = 0;
+                if (profitMargin == null && StringUtils.isNotBlank(profit)) {
+                    if (Double.parseDouble(profit) * 100 >= profitMargin) {
+                        ALLOW_COMMISSION_PAYMENT = 1;
+                    }
+                }
+                DBSql.update("update BO_EU_DNCTT_CONTRACT set ALLOW_COMMISSION_PAYMENT=? where ID=?", new Object[]{ALLOW_COMMISSION_PAYMENT, CONTRACT_ID});
+            } catch (Exception e) {
+                e.printStackTrace();
+
+                DBSql.update("update BO_EU_DNCTT_CONTRACT set ALLOW_COMMISSION_PAYMENT=0 where ID=?", new Object[]{CONTRACT_ID});
+            }
         }
 
         //修改服务

com.awspaas.user.apps.donenow_ctt/src/com/awspaas/user/apps/donenow_ctt/service/contractCommissionService.java

@@ -171,7 +171,8 @@ public class contractCommissionService {
                     String FEE_DATE = DBSql.getString("SELECT MAX(c.RECEIVE_DATE) FROM BO_EU_DNCTT_INVOICE_PLAN a JOIN BO_EU_DNCTT_INVOICE_PLAN_DETAIL b ON a.BINDID=b.BINDID JOIN BO_EU_DNCTT_INVOICE_PLAN_RECEIVE c ON a.BINDID=c.BINDID WHERE a.ISEND=1 AND b.ACCOUNT_DEDUCTION_ID=?  ", new Object[]{ACCOUNT_DEDUCTION_ID});
                     if (StringUtils.isBlank(FEE_DATE))
                         continue;
-
+                    serviceLogger.info("FEE_DATE=" + FEE_DATE);
+                    FEE_DATE = FEE_DATE.substring(0, 10);
                     //获取 FEE_DATE 的下个月
                     FEE_DATE = contractService.getLocalDate(FEE_DATE).plusMonths(1).format(DateTimeFormatter.ofPattern("yyyy-MM"));
                     period.set("FEE_DATE", FEE_DATE);
@@ -190,11 +191,17 @@ public class contractCommissionService {
                         SDK.getProcessAPI().deleteById(comssionperiodBindId, uc.getUID());
                     }
                     //获取合同服务的周期
-                    RowMap service = DBSql.getMap("SELECT b.PERIOD_BEGIN_DATE,b.PERIOD_END_DATE,b.PERIOD_COST,b.CONTRACT_SERVICE_ID from BO_EU_DNCRM_ACCOUNT_DEDUCTION a JOIN BO_EU_DNCTT_CONTRACT_SERVICE_PERIOD b ON a.OBJECT_ID=b.ID AND a.TYPE_ID=1325 AND a.ID=? ", new Object[]{ACCOUNT_DEDUCTION_ID});
+                    RowMap service = DBSql.getMap("SELECT b.PERIOD_BEGIN_DATE,b.PERIOD_END_DATE,b.PERIOD_COST,b.CONTRACT_SERVICE_ID,b.CONTRACT_ID,c.MINIMUM_PROFIT_MARGIN,c.ALLOW_COMMISSION_PAYMENT from BO_EU_DNCRM_ACCOUNT_DEDUCTION a JOIN BO_EU_DNCTT_CONTRACT_SERVICE_PERIOD b ON a.OBJECT_ID=b.ID AND a.TYPE_ID=1325 JOIN BO_EU_DNCTT_CONTRACT c ON b.CONTRACT_ID=c.ID WHERE  a.ID=? ", new Object[]{ACCOUNT_DEDUCTION_ID});
 
                     RowMap ded = DBSql.getMap("select * from BO_EU_DNCRM_ACCOUNT_DEDUCTION where ID=?", new Object[]{ACCOUNT_DEDUCTION_ID});
 
                     if (service != null) {
+
+                        //利润不达标，不需要计算佣金
+                        if (RULE_CATE.equals("4648") && service.getDouble("MINIMUM_PROFIT_MARGIN") > 0 && service.getDouble("ALLOW_COMMISSION_PAYMENT") == 0) {
+                            continue;
+                        }
+
                         period.set("CONTRACT_SERVICE_ID", service.get("CONTRACT_SERVICE_ID"));
                         period.set("PERIOD_BEGIN_DATE", service.get("PERIOD_BEGIN_DATE"));//周期开始时间
                         period.set("PERIOD_END_DATE", service.get("PERIOD_END_DATE"));//周期结束
@@ -211,9 +218,10 @@ public class contractCommissionService {
                             COST_INCLUDE_TAX = COST_INCLUDE_TAX.subtract(RECEIVED_DOLLARS_INCLUDE_TAX);
 
                             if (lastPeriod.get("COST_BF_INCLUDE_TAX") != null) {
-                                COST_INCLUDE_TAX = COST_INCLUDE_TAX.subtract(TypeUtil.convert(lastPeriod.get("COST_BF_INCLUDE_TAX"), BigDecimal.class));
+                                COST_INCLUDE_TAX = COST_INCLUDE_TAX.add(TypeUtil.convert(lastPeriod.get("COST_BF_INCLUDE_TAX"), BigDecimal.class));
                             }
 
+                            //本次转结成本
                             if (COST_INCLUDE_TAX.compareTo(BigDecimal.ZERO) > 0) {
                                 period.set("COST_BF_INCLUDE_TAX", COST_INCLUDE_TAX);
                             }
@@ -264,7 +272,6 @@ public class contractCommissionService {
                         period.set("COST_BF", TypeUtil.convert(period.get("COST_BF_INCLUDE_TAX"), BigDecimal.class).divide(fu_tax, 10, BigDecimal.ROUND_HALF_UP));//上期结转成本（不含税）
                     // }
 
-
                     switch (RULE_CATE) {
                         case "4647": {
                             if (commission.getString("INCLUDE_TAX").equals("1")) {
@@ -289,10 +296,10 @@ public class contractCommissionService {
                             //销售净利百分比：针对已经全部收款的合同服务进行生成，创建一条合同佣金周期记录
                             BigDecimal RATIO = TypeUtil.convert(commission.get("RATIO"), BigDecimal.class);
                             //使用含税价
+
                             if (commission.getString("INCLUDE_TAX").equals("1")) {
                                 COMMISSION_DOLLARS = TypeUtil.convert(bill.get("RECEIVE_AMOUNT"), BigDecimal.class);
 
-                                //本期成本（含税）
                                 if (period.containsKey("COST_INCLUDE_TAX") && period.get("COST_INCLUDE_TAX") != null)
                                     COMMISSION_DOLLARS = COMMISSION_DOLLARS.subtract(TypeUtil.convert(period.get("COST_INCLUDE_TAX"), BigDecimal.class));
 
@@ -300,13 +307,6 @@ public class contractCommissionService {
                                 if (period.containsKey("COST_BF_INCLUDE_TAX") && period.get("COST_BF_INCLUDE_TAX") != null)
                                     COMMISSION_DOLLARS = COMMISSION_DOLLARS.subtract(TypeUtil.convert(period.get("COST_BF_INCLUDE_TAX"), BigDecimal.class));
 
-                                period.set("NET_PROFIT", COMMISSION_DOLLARS);//利润
-
-                                COMMISSION_DOLLARS = COMMISSION_DOLLARS.multiply(RATIO).divide(BigDecimal.valueOf(100), 10, BigDecimal.ROUND_HALF_UP);
-
-                                COMMISSION_DOLLARS = COMMISSION_DOLLARS.divide(BigDecimal.ONE.add(tax), 10, BigDecimal.ROUND_HALF_UP);
-                                period.set("COMMISSION_DOLLARS", COMMISSION_DOLLARS);//佣金金额
-
                             } else {
                                 //使用不含税价
                                 COMMISSION_DOLLARS = TypeUtil.convert(period.get("RECEIVED_DOLLARS"), BigDecimal.class);//不含税已收
@@ -319,13 +319,16 @@ public class contractCommissionService {
                                 if (period.containsKey("COST_BF") && period.get("COST_BF") != null)
                                     COMMISSION_DOLLARS = COMMISSION_DOLLARS.subtract(TypeUtil.convert(period.get("COST_BF"), BigDecimal.class));
 
-                                period.set("NET_PROFIT", COMMISSION_DOLLARS);//利润
+                            }
 
+                            if (COMMISSION_DOLLARS.compareTo(BigDecimal.ZERO) > 0) {
+                                period.set("NET_PROFIT", COMMISSION_DOLLARS);//利润
                                 COMMISSION_DOLLARS = COMMISSION_DOLLARS.multiply(RATIO).divide(BigDecimal.valueOf(100), 10, BigDecimal.ROUND_HALF_UP);
-
                                 COMMISSION_DOLLARS = COMMISSION_DOLLARS.divide(BigDecimal.ONE.add(tax), 10, BigDecimal.ROUND_HALF_UP);
                                 period.set("COMMISSION_DOLLARS", COMMISSION_DOLLARS);//佣金金额
-
+                            } else {
+                                period.set("NET_PROFIT", BigDecimal.ZERO);
+                                period.set("COMMISSION_DOLLARS", BigDecimal.ZERO);
                             }
 
                         }

com.awspaas.user.apps.donenow_ivt/src/com/awspaas/user/apps/donenow_ivt/controller/ivtOrderController.java

@@ -15,6 +15,7 @@ import com.actionsoft.bpms.util.DBSql;
 import com.actionsoft.bpms.util.TypeUtil;
 import com.actionsoft.sdk.local.SDK;
 import com.actionsoft.sdk.local.api.Logger;
+import com.actionsoft.sdk.local.api.TaskAPI;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
@@ -626,7 +627,8 @@ public class ivtOrderController {
         sql = sql.substring(0, sql.length() - 1) + ")";
         List<RowMap> costList = DBSql.getMaps(sql, Arrays.stream(serviceArr).toArray());
 
-        if (costList.isEmpty()) return ResponseObject.newErrResponse("没有找到对应的合同产品");
+        if (costList.isEmpty())
+            return ResponseObject.newErrResponse("没有找到对应的合同产品");
 
 
         String costIds = costList.stream().map(cost -> cost.getString("ID")).collect(Collectors.joining(","));
@@ -648,6 +650,45 @@ public class ivtOrderController {
 
         return createPurchaseOrder(uc, costIds);
     }
+456
+
+    @Mapping(value = "com.awspaas.user.apps.donenow_ivt.contract_serviceOrder_exec", session = false, noSessionEvaluate = "无安全隐患", noSessionReason = "批量生产")
+    public String contractServicExec() throws SQLException {
+        List<RowMap> services = DBSql.getMaps("SELECT CONTRACT_ID,GROUP_CONCAT(ID) IDS FROM bo_eu_dnctt_contract_service WHERE CONTRACT_ID in (SELECT ID FROM BO_EU_DNCTT_CONTRACT WHERE FRAMEWORK='7c2841c3-8f51-4dea-a6ea-984d9b9c3574' AND NO NOT LIKE '%old%' ) GROUP BY CONTRACT_ID");
+        UserContext uc = UserContext.fromUID("admin");
+        for (RowMap service : services) {
+            String contractId = service.getString("CONTRACT_ID");
+            String serviceIds = service.getString("IDS");
+            createPurchaseOrderByServiceId(uc, serviceIds);
+
+        }
+
+        return "ok";
+    }
+
+    @Mapping(value = "com.awspaas.user.apps.donenow_ivt.contract_serviceOrder_exec2", session = false, noSessionEvaluate = "无安全隐患", noSessionReason = "批量生产")
+    public String contractServicExec2() throws SQLException {
+        List<RowMap> services = DBSql.getMaps("SELECT c.ID FROM bo_eu_dnctt_contract_service a JOIN bo_eu_dnivt_order_product b ON a.ID=b.CONTRACT_SERVICE_ID JOIN wfc_task c ON b.BINDID=c.PROCESSINSTID WHERE  c.CONTROLSTATE='active' AND c.TASKSTATE=1  AND a.CONTRACT_ID in (SELECT ID FROM BO_EU_DNCTT_CONTRACT WHERE FRAMEWORK='7c2841c3-8f51-4dea-a6ea-984d9b9c3574' AND NO NOT LIKE '%old%' ) ");
+        UserContext uc = UserContext.fromUID("admin");
+
+        TaskAPI taskAPI = SDK.getTaskAPI();
+
+        for (RowMap service : services) {
+            String taskId = service.getString("ID");
+            taskAPI.completeTask(taskId, "admin");
+        }
+
+
+        DBSql.update("UPDATE bo_eu_dnctt_contract_service a \n" +
+                "JOIN bo_eu_dnivt_order_product b ON a.ID=b.CONTRACT_SERVICE_ID \n" +
+                "JOIN bo_eu_dnivt_order c ON b.BINDID=c.BINDID \n" +
+                "JOIN BO_EU_DNCTT_CONTRACT d ON a.CONTRACT_ID=d.ID \n" +
+                "JOIN BO_EU_1763622342236 e ON d.`NAME`=e.`NAME` \n" +
+                "SET c.PURCHASE_ORDER_NO=e.NO\n" +
+                "WHERE  d.FRAMEWORK='7c2841c3-8f51-4dea-a6ea-984d9b9c3574' AND d.NO NOT LIKE '%old%'");
+
+        return "ok";
+    }
 
     /**
      * 创建采购订单