蓝云NC部门达成代码更新

mjava-lanyun/src/main/java/com/malk/lanyun/controller/TimerController.java

@@ -69,6 +69,11 @@ public class TimerController {
         ncService.getNcCollection();
         return McR.success();
     }
+    @RequestMapping("testGetNcCollection")
+    McR testGetNcCollection(@RequestBody Map data) {
+        ncService.getNcCollection(data);
+        return McR.success();
+    }
 
     @RequestMapping("testFive")
     McR testFive() {

mjava-lanyun/src/main/java/com/malk/lanyun/service/NCService.java

@@ -31,4 +31,6 @@ public interface NCService {
     void ncToYiDa();
 
     void getByMonth(@RequestBody Map data);
+
+    void getNcCollection(Map data);
 }

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

@@ -292,8 +292,8 @@ public class NCServiceImpl implements NCService {
                     "\tLEFT JOIN bd_account ON bd_accasoa.pk_account = bd_account.pk_account \n" +
                     "WHERE\n" +
                     "\tsubstring( bd_account.CODE, 0, 5 ) IN ( '5001', '5301', '6602', '6601', '6001', '6051' ) \n" +
-                    "\tAND gl_detail.yearv = '2025' \n" +
-                    "\tAND gl_detail.adjustperiod = '04' \n" +
+                    "\tAND gl_detail.yearv = '"+year+"' \n" +
+                    "\tAND gl_detail.adjustperiod = '"+month+"' \n" +
                     "\tAND org_accountingbook.CODE IN ( 'A01-0004', 'A02-0004', 'A11-0004', 'A03-0004', 'A06-0004', 'A04-0004', 'A05-0004', 'A10-0004' ) \n" +
                     "\tAND gl_detail.discardflagv <> 'Y' \n" +
                     "\tAND gl_detail.dr = 0 \n" +
@@ -320,23 +320,29 @@ public class NCServiceImpl implements NCService {
             resultSet = statement.executeQuery(sql);
 
             while (resultSet.next()) {
-                Map hashMap = new HashMap();
-
-                String yearAndNonth = year +"-"+month;
-                hashMap.put("dateField_m0dkzhwp", UtilDateTime.parse(yearAndNonth,"yyyy-MM"));
-                hashMap.put("textField_m0dkzhwo", yearAndNonth);
-                hashMap.put("textField_m0dkzhwu",resultSet.getString("kmcode"));
-                hashMap.put("textField_m0dkzhwv",resultSet.getString("kmname"));
-                hashMap.put("textField_mbj1j8n2",resultSet.getString("ccode"));
-                hashMap.put("textField_m0eudqp0",resultSet.getString("cname"));//部门
-                hashMap.put("numberField_m0dkzhx1",resultSet.getBigDecimal("JFFS"));
-
-                ydClient.operateData(YDParam.builder()
-                        .appType("APP_ERBDTFS82HOVBPL3NFH0")
-                        .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
-                        .formUuid("FORM-5654B7C22E7546E9BBE7B4EF46DE08BAXZXU")
-                        .formDataJson(JSON.toJSONString(hashMap))
-                        .build(), YDConf.FORM_OPERATION.create);
+                if (ObjectUtil.isNotNull(resultSet.getString("xmcode"))){
+                    Map hashMap = new HashMap();
+
+                    String yearAndNonth = year +"-"+month;
+                    hashMap.put("dateField_m0dkzhwp", UtilDateTime.parse(yearAndNonth,"yyyy-MM"));
+                    hashMap.put("textField_m0dkzhwo", yearAndNonth);
+                    hashMap.put("textField_m0dkzhwu",resultSet.getString("kmcode"));
+                    hashMap.put("textField_m0dkzhwv",resultSet.getString("kmname"));
+                    hashMap.put("textField_mbj1j8n2",resultSet.getString("ccode"));//合并id
+                    hashMap.put("textField_m0eudqp0",resultSet.getString("cname"));//合并名称
+                    hashMap.put("textField_mbk7mt4i",resultSet.getString("bmcode"));//机关id
+                    hashMap.put("textField_mbk7mt4l",resultSet.getString("bmname"));//机关名称
+                    hashMap.put("textField_mbk7mt4o",resultSet.getString("xmcode"));//项目id
+                    hashMap.put("textField_mbk7mt4q",resultSet.getString("xmname"));//项目名称
+                    hashMap.put("numberField_m0dkzhx1",resultSet.getBigDecimal("JFFS"));
+
+                    ydClient.operateData(YDParam.builder()
+                            .appType("APP_ERBDTFS82HOVBPL3NFH0")
+                            .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+                            .formUuid("FORM-5654B7C22E7546E9BBE7B4EF46DE08BAXZXU")
+                            .formDataJson(JSON.toJSONString(hashMap))
+                            .build(), YDConf.FORM_OPERATION.create);
+                }
             }
         } catch (Exception e) {
             log.info("数据库连接异常"+e.toString());
@@ -1875,4 +1881,115 @@ public class NCServiceImpl implements NCService {
             }
         }
     }
+
+    @Override
+    public void getNcCollection(Map data) {
+        String year = data.get("year").toString();
+        String month = data.get("month").toString();
+        // 获取当前年
+        deleteMonthDate("FORM-5654B7C22E7546E9BBE7B4EF46DE08BAXZXU","textField_m0dkzhwo", year , month);
+
+        Connection connection = null;
+        Statement statement = null;
+        ResultSet resultSet = null;
+        try {
+            // 加载 JDBC 驱动
+            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
+            // 建立连接
+            connection = DriverManager.getConnection(sqlBean.getUrl(), sqlBean.getUsername(), sqlBean.getPassword());
+
+            // 创建 Statement 对象
+            statement = connection.createStatement();
+
+            // 测试sql 执行查询
+            String sql = "SELECT\n" +
+                    "\torg_accountingbook.CODE orgcode,\n" +
+                    "\torg_accountingbook.NAME orgname,\n" +
+                    "\tbd_account.CODE kmcode,\n" +
+                    "\tsubstring( bd_account.CODE, 0, 5 ) kmbm,\n" +
+                    "\tbd_accasoa.NAME kmname,\n" +
+                    "\tbd_accasoa.dispname KMMC,\n" +
+                    "\tISNULL(org_dept.CODE,bd_project.project_code) ccode,\n" +
+                    "\tISNULL(org_dept.NAME,bd_project.project_name) cname,\n" +
+                    "\torg_dept.CODE bmcode,\n" +
+                    "\torg_dept.NAME bmname,\n" +
+                    "\tbd_project.project_code xmcode,\n" +
+                    "\tbd_project.project_name xmname,\n" +
+                    "\tSUM( gl_detail.localdebitamount ) JFFS \n" +
+                    "FROM\n" +
+                    "\tgl_detail gl_detail\n" +
+                    "\tLEFT JOIN gl_docfree1 ON gl_detail.assid = gl_docfree1.assid\n" +
+                    "\tLEFT JOIN org_dept ON gl_docfree1.f1 = org_dept.pk_dept\n" +
+                    "\tLEFT JOIN bd_project ON gl_docfree1.f10 = bd_project.pk_project\n" +
+                    "\tLEFT JOIN org_accountingbook ON gl_detail.pk_accountingbook = org_accountingbook.pk_accountingbook\n" +
+                    "\tLEFT JOIN bd_accasoa ON gl_detail.pk_accasoa = bd_accasoa.pk_accasoa\n" +
+                    "\tLEFT JOIN bd_account ON bd_accasoa.pk_account = bd_account.pk_account \n" +
+                    "WHERE\n" +
+                    "\tsubstring( bd_account.CODE, 0, 5 ) IN ( '5001', '5301', '6602', '6601', '6001', '6051' ) \n" +
+                    "\tAND gl_detail.yearv = '"+year+"' \n" +
+                    "\tAND gl_detail.adjustperiod = '"+month+"' \n" +
+                    "\tAND org_accountingbook.CODE IN ( 'A01-0004', 'A02-0004', 'A11-0004', 'A03-0004', 'A06-0004', 'A04-0004', 'A05-0004', 'A10-0004' ) \n" +
+                    "\tAND gl_detail.discardflagv <> 'Y' \n" +
+                    "\tAND gl_detail.dr = 0 \n" +
+                    "\tAND gl_detail.voucherkindv <> 255 \n" +
+                    "\tAND gl_detail.tempsaveflag <> 'Y' \n" +
+                    "\tAND gl_detail.voucherkindv <> 5 \n" +
+                    "\tAND ( gl_docfree1.F1 <> 'NN/A' OR gl_docfree1.F10 <> 'NN/A' ) \n" +
+                    "\tAND 1 = 1 \n" +
+                    "GROUP BY\n" +
+                    "\tgl_detail.pk_accasoa,\n" +
+                    "\tgl_detail.pk_accountingbook,\n" +
+                    "\tgl_detail.yearv,\n" +
+                    "\torg_dept.CODE,\n" +
+                    "\torg_dept.NAME,\n" +
+                    "\torg_accountingbook.CODE,\n" +
+                    "\torg_accountingbook.NAME,\n" +
+                    "\tbd_accasoa.dispname,\n" +
+                    "\tbd_account.CODE,\n" +
+                    "\tbd_accasoa.NAME,\n" +
+                    "\tbd_project.project_code,\n" +
+                    "\tbd_project.project_name";
+
+
+            resultSet = statement.executeQuery(sql);
+
+            while (resultSet.next()) {
+                if (ObjectUtil.isNotNull(resultSet.getString("xmcode"))){
+                    Map hashMap = new HashMap();
+
+                    String yearAndNonth = year +"-"+month;
+                    hashMap.put("dateField_m0dkzhwp", UtilDateTime.parse(yearAndNonth,"yyyy-MM"));
+                    hashMap.put("textField_m0dkzhwo", yearAndNonth);
+                    hashMap.put("textField_m0dkzhwu",resultSet.getString("kmcode"));
+                    hashMap.put("textField_m0dkzhwv",resultSet.getString("kmname"));
+                    hashMap.put("textField_mbj1j8n2",resultSet.getString("ccode"));//合并id
+                    hashMap.put("textField_m0eudqp0",resultSet.getString("cname"));//合并名称
+                    hashMap.put("textField_mbk7mt4i",resultSet.getString("bmcode"));//机关id
+                    hashMap.put("textField_mbk7mt4l",resultSet.getString("bmname"));//机关名称
+                    hashMap.put("textField_mbk7mt4o",resultSet.getString("xmcode"));//项目id
+                    hashMap.put("textField_mbk7mt4q",resultSet.getString("xmname"));//项目名称
+                    hashMap.put("numberField_m0dkzhx1",resultSet.getBigDecimal("JFFS"));
+
+                    ydClient.operateData(YDParam.builder()
+                            .appType("APP_ERBDTFS82HOVBPL3NFH0")
+                            .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+                            .formUuid("FORM-5654B7C22E7546E9BBE7B4EF46DE08BAXZXU")
+                            .formDataJson(JSON.toJSONString(hashMap))
+                            .build(), YDConf.FORM_OPERATION.create);
+                }
+            }
+        } catch (Exception e) {
+            log.info("数据库连接异常"+e.toString());
+            e.printStackTrace();
+        } finally {
+            // 关闭资源
+            try {
+                if (resultSet != null) resultSet.close();
+                if (statement != null) statement.close();
+                if (connection != null) connection.close();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
 }

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

@@ -1212,9 +1212,9 @@ public class TimerServiceImpl implements TimerService {
                                 }
                                 e.put("numberField_lv1qokdj",String.format("%.2f", unitPrice/(1+fax/100)));
                                 e.put("numberField_lr383i4n",unitPrice * kcjyl);
-                                if (!ObjectUtil.isNotNull(e.get("textField_ludq7er4"))){
-                                    e.put("textField_ludq7er4",code + "_6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
-                                }
+//                                if (!ObjectUtil.isNotNull(e.get("textField_ludq7er4"))){
+                                e.put("textField_ludq7er4",code + "_6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
+//                                }
                             }
                         }else {
                             e.put("textField_ludokwa5","");
@@ -1228,7 +1228,7 @@ public class TimerServiceImpl implements TimerService {
                             e.put("numberField_lv1qokdj",0.0);
                             e.put("numberField_lr383i4n",0.0);
 //                            if (!ObjectUtil.isNotNull(e.get("textField_ludq7er4"))){
-                                e.put("textField_ludq7er4","6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
+                            e.put("textField_ludq7er4","6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
 //                            }
                         }
                     }
@@ -1275,7 +1275,7 @@ public class TimerServiceImpl implements TimerService {
                                 e.put("numberField_lv1qokdk",String.format("%.2f", unitPrice/(1+fax/100)));
                                 e.put("numberField_lxd0y352",unitPrice * kcjyl);
 //                                if (!ObjectUtil.isNotNull(e.get("textField_ludqgh1u"))){
-                                    e.put("textField_ludqgh1u",code+ "_6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
+                                e.put("textField_ludqgh1u",code+ "_6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
 //                                }
                             }
                         }else {
@@ -1289,9 +1289,9 @@ public class TimerServiceImpl implements TimerService {
                             e.put("numberField_ludqgh1o",0.0);//实际金额小计
                             e.put("numberField_lv1qokdk",0.0);
                             e.put("numberField_lxd0y352",0.0);
-                            if (!ObjectUtil.isNotNull(e.get("textField_ludqgh1u"))){
-                                e.put("textField_ludqgh1u","6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
-                            }
+//                            if (!ObjectUtil.isNotNull(e.get("textField_ludqgh1u"))){
+                            e.put("textField_ludqgh1u","6038646631836291_"+LocalDateTimeUtil.format(LocalDateTime.now(), "yyyyMMddHHmmssS"));
+//                            }
                         }
                     }
                 });