合同导入

src/main/java/common/service/impl/ContractServiceImpl.java

@@ -179,7 +179,6 @@ public class ContractServiceImpl implements ContractService {
     TransactionUtils transactionUtils;
 
 
-
     @Override
     public Map<String, Object> checkAccount(String email, String platfrom) {
         Map<String, Object> map = new HashMap<>();
@@ -2124,7 +2123,10 @@ public class ContractServiceImpl implements ContractService {
         }
 
         int row_already = titleKey.size();
-        String extend_row_sql = "platform,product,my_body_code,create_time";
+        String extend_row_sql = "platform,product,my_body_code,create_time,code_num,type,status,ds," +
+                "create_account,create_name,extra_flow,relation_contract,invoice_money,first_back_id";
+
+        int extend_size = extend_row_sql.split(",").length;
 
         DataFormatter formatter = new DataFormatter();
         int rowNumber = sheet.getLastRowNum();
@@ -2132,8 +2134,9 @@ public class ContractServiceImpl implements ContractService {
 
         for (int j = 1; j <= rowNumber; j++) {
             Row row_data = sheet.getRow(j);
-            Object[] s_data = new Object[titleKey.size() + 4];
+            Object[] s_data = new Object[titleKey.size() + extend_size];
             String bodyCode = null;
+            String ds = null;
 
             for (int w = 0; w < titleKey.size(); w++) {
                 String sheetTitle = titleKey.get(w);
@@ -2168,7 +2171,7 @@ public class ContractServiceImpl implements ContractService {
                         if (!CONTRACT_TYPE_NAME.containsKey(dataSTR)) {
                             return ResultModel.ERROR("第" + line_num + "行[签约类型]错误");
                         } else {
-                            s_data[w] = salseMap.get(dataSTR);
+                            s_data[w] = CONTRACT_TYPE_NAME.get(dataSTR);
                         }
                     } else if ("price_level".equals(sheetTitle)) {
                         if (packageMap != null && !packageMap.containsKey(dataSTR)) {
@@ -2185,6 +2188,11 @@ public class ContractServiceImpl implements ContractService {
                             String pattern = "yyyy/MM/dd";
                             DateTime dateTime = DateTime.parse(dataSTR, DateTimeFormat.forPattern(pattern));
                             s_data[w] = dateTime.toString("yyyy-MM-dd");
+
+                            if("start_date".equals(sheetTitle)){
+                                ds = s_data[w].toString();
+                            }
+
                         } catch (Exception e) {
                             return ResultModel.ERROR("第" + line_num + "行[日期]错误");
                         }
@@ -2199,6 +2207,17 @@ public class ContractServiceImpl implements ContractService {
             s_data[row_already + 1] = platform;
             s_data[row_already + 2] = bodyCode;
             s_data[row_already + 3] = new Date();
+            s_data[row_already + 4] = 0;
+            s_data[row_already + 5] = "main";
+            s_data[row_already + 6] = "backnone";
+            s_data[row_already + 7] = ds;
+//            create_account,create_name,extra_flow,relation_contract,invoice_money,first_back_id
+            s_data[row_already + 8] = 0;
+            s_data[row_already + 9] = "导入";
+            s_data[row_already + 10] = 0;
+            s_data[row_already + 11] = -1;
+            s_data[row_already + 12] = 0;
+            s_data[row_already + 13] = 0;
             //批量添加数据
             args_data.add(s_data);
         }
@@ -2208,7 +2227,7 @@ public class ContractServiceImpl implements ContractService {
         sql.append(extend_row_sql);
         sql.append(") values (");
 
-        for (int ed = 0, s = row_already + 4; ed < s; ed++) {
+        for (int ed = 0, s = row_already + extend_size; ed < s; ed++) {
             if (ed == 0) {
                 sql.append("?");
             } else {
@@ -2217,12 +2236,11 @@ public class ContractServiceImpl implements ContractService {
         }
         sql.append(")");
         logger.info("sql[{}]", sql.toString());
+
 //        TransactionStatus transactionStatus = transactionUtils.begin();
-//        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
-//        jdbcTemplate.batchUpdate(sql.toString(), args_data);
+        jdbcTemplate.batchUpdate(sql.toString(), args_data);
 //        transactionUtils.commit(transactionStatus);
 
-        jdbcTemplate.batchUpdate(sql.toString(),args_data);
         return ResultModel.OK();
 
     }