各项目经营分析报表更新

mjava-lanyun/src/main/java/com/malk/lanyun/service/impl/TimerServiceImpl.java

@@ -447,25 +447,16 @@ public class TimerServiceImpl implements TimerService {
                 .formUuid("FORM-954C78969A864D95A1BC0CE9F69299E8VI38")
                 .searchFieldJson(JSON.toJSONString(UtilMap.map("radioField_m0dkcxod", "否")))
                 .build());
-        dataList.forEach(e->{
-            ydClient.operateData(YDParam.builder()
-                    .appType("APP_ERBDTFS82HOVBPL3NFH0")
-                    .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
-                    .formInstanceId(UtilMap.getString(e, "formInstanceId"))
-//                    .useLatestVersion(true)
-//                    .updateFormDataJson(JSONObject.toJSONString(new HashMap<>()))
-                    .updateFormDataJson(JSON.toJSONString(UtilMap.map("radioField_m0dkcxod", "是")))
-                    .build(), YDConf.FORM_OPERATION.update);
-        });
+
         Connection connection = null;
         PreparedStatement ps = null;
         try {
             Class.forName(driver);
             connection = DriverManager.getConnection(url, username, password);
             String sql = "INSERT INTO `lanyun_project_analysis`(`project_name`, `belong_project`, `month`, " +
-                    "`status`, `d_level`, `predict_income`, `open`, `income`, `person`, `person_cost`, `material`, `other_cost`, " +
+                    "`status`, `predict_income`, `open`, `income`, `person`, `person_cost`, `material`, `other_cost`, " +
                     "`cost_sum`, `taxes`, `gross_profit`, `gross_margin`, `overhead`, `corporate_income_tax`, `net_profit`, " +
-                    "`net_margin`, `format`, `customer_system`, `profit_loss`, `approach_date`, `level`, `notes`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?);";
+                    "`net_margin`, `format`, `customer_system`, `profit_loss`, `approach_date`, `level`, `notes`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?);";
 
             ps = connection.prepareStatement(sql);
             for (int i = 0; i < dataList.size(); i++) {
@@ -473,29 +464,36 @@ public class TimerServiceImpl implements TimerService {
                 ps.setObject(2,dataList.get(i).get("textField_bheotm5"));
                 ps.setObject(3,dataList.get(i).get("dateField_lcwv382"));
                 ps.setObject(4,dataList.get(i).get("textField_pa6o780"));
-                ps.setObject(5,dataList.get(i).get("textField_lz2jttrl"));
-                ps.setObject(6,dataList.get(i).get("numberField_5wyyb42"));
-                ps.setObject(7,dataList.get(i).get("numberField_c4acnrg"));
-                ps.setObject(8,dataList.get(i).get("numberField_zjdki9k"));
-                ps.setObject(9,dataList.get(i).get("numberField_hg6jznm"));
-                ps.setObject(10,dataList.get(i).get("numberField_7ga9c5w"));
-                ps.setObject(11,dataList.get(i).get("numberField_c3cqsfv"));
-                ps.setObject(12,dataList.get(i).get("numberField_avaexyf"));
-                ps.setObject(13,dataList.get(i).get("numberField_gub2ul5"));
-                ps.setObject(14,dataList.get(i).get("numberField_hqiac12"));
-                ps.setObject(15,dataList.get(i).get("numberField_lz6mt3xq"));
-                ps.setObject(16,dataList.get(i).get("numberField_lz9n3fm9"));
-                ps.setObject(17,dataList.get(i).get("numberField_ln701sy"));
-                ps.setObject(18,dataList.get(i).get("numberField_fmhzxdr"));
-                ps.setObject(19,dataList.get(i).get("numberField_lz6mt3xr"));
-                ps.setObject(20,dataList.get(i).get("numberField_lz9n3fma"));
-                ps.setObject(21,dataList.get(i).get("textField_tpb3m2f"));
-                ps.setObject(22,dataList.get(i).get("textField_2adicsn"));
-                ps.setObject(23,dataList.get(i).get("textField_1yw4mx4"));
-                ps.setObject(24,dataList.get(i).get("dateField_ji5yfvf"));
-                ps.setObject(25,dataList.get(i).get("textField_h2qx5nz"));
-                ps.setObject(26,dataList.get(i).get("textField_35paoph"));
-
+                ps.setObject(5,dataList.get(i).get("numberField_5wyyb42"));
+                ps.setObject(6,dataList.get(i).get("numberField_c4acnrg"));
+                ps.setObject(7,dataList.get(i).get("numberField_zjdki9k"));
+                ps.setObject(8,dataList.get(i).get("numberField_hg6jznm"));
+                ps.setObject(9,dataList.get(i).get("numberField_7ga9c5w"));
+                ps.setObject(10,dataList.get(i).get("numberField_c3cqsfv"));
+                ps.setObject(11,dataList.get(i).get("numberField_avaexyf"));
+                ps.setObject(12,dataList.get(i).get("numberField_gub2ul5"));
+                ps.setObject(13,dataList.get(i).get("numberField_hqiac12"));
+                ps.setObject(14,dataList.get(i).get("numberField_lz6mt3xq"));
+                ps.setObject(15,dataList.get(i).get("numberField_lz9n3fm9"));
+                ps.setObject(16,dataList.get(i).get("numberField_ln701sy"));
+                ps.setObject(17,dataList.get(i).get("numberField_fmhzxdr"));
+                ps.setObject(18,dataList.get(i).get("numberField_lz6mt3xr"));
+                ps.setObject(19,dataList.get(i).get("numberField_lz9n3fma"));
+                ps.setObject(20,dataList.get(i).get("textField_tpb3m2f"));
+                ps.setObject(21,dataList.get(i).get("textField_2adicsn"));
+                double net_margin = Double.parseDouble(dataList.get(i).get("numberField_lz9n3fma").toString());
+                String profit_loss = "";
+                if (net_margin < 0){
+                    profit_loss = "亏损";
+                }else if (net_margin >=0 && net_margin <=0.05){
+                    profit_loss = "净利较低";
+                }else if(net_margin > 0.05){
+                    profit_loss = "盈利";
+                }
+                ps.setObject(22,dataList.get(i).get("textField_1yw4mx4") == null ? null : profit_loss);
+                ps.setObject(23,dataList.get(i).get("dateField_ji5yfvf"));
+                ps.setObject(24,dataList.get(i).get("textField_h2qx5nz"));
+                ps.setObject(25,dataList.get(i).get("textField_35paoph"));
                 ps.addBatch();
                 if (i%500==0){
                     ps.executeBatch();
@@ -507,6 +505,15 @@ public class TimerServiceImpl implements TimerService {
         } catch (Exception exception) {
             throw new RuntimeException(exception);
         }
-
+        dataList.forEach(e->{
+            ydClient.operateData(YDParam.builder()
+                    .appType("APP_ERBDTFS82HOVBPL3NFH0")
+                    .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+                    .formInstanceId(UtilMap.getString(e, "formInstanceId"))
+//                    .useLatestVersion(true)
+//                    .updateFormDataJson(JSONObject.toJSONString(new HashMap<>()))
+                    .updateFormDataJson(JSON.toJSONString(UtilMap.map("radioField_m0dkcxod", "是")))
+                    .build(), YDConf.FORM_OPERATION.update);
+        });
     }
 }