Przeglądaj źródła

Merge remote-tracking branch 'origin/matser' into matser

Li Yuan 1 rok temu
rodzic
commit
196196b8a9

+ 11 - 8
ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/sysdata/controller/UpdateDataTableController.java

@@ -180,20 +180,23 @@ public class UpdateDataTableController {
         APIResult<Void> apiResult = new APIResult<>();
 
         /*鉴权,当前接口只允许pc端发送请求 */
-        if(data.isEmpty() || !updateDataTableService.sigVerify(data)){
-            apiResult.setState(StateEnum.ERROR.getCode());
-            apiResult.setMessage("调用接口时,签名不合法!");
-            return apiResult;
-        }
+//        if(data.isEmpty() || !updateDataTableService.sigVerify(data)){
+//            apiResult.setState(StateEnum.ERROR.getCode());
+//            apiResult.setMessage("调用接口时,签名不合法!");
+//            return apiResult;
+//        }
 
         Map mapData = JSONObject.parseObject(data); /*转换成map*/
+        String ciphertext =(String) mapData.get("ciphertext");
         String tableName = null;
         Map paramCond = null;
         List<Map<String, String>> paramWhere = null; /*条件 : 值*/
         try {
-            tableName = (String) mapData.get("tableName");
-            paramCond = (Map) mapData.get("paramCond");
-            paramWhere = (List<Map<String, String>>) mapData.get("paramWhere");
+            String decrypt = decrypt(ciphertext);
+            Map jsonMap = JSONObject.parseObject(decrypt);
+            tableName = (String) jsonMap.get("tableName");
+            paramCond = (Map) jsonMap.get("paramCond");
+            paramWhere = (List<Map<String, String>>) jsonMap.get("paramWhere");
         } catch (Exception e) {
             e.printStackTrace();
             apiResult.setState(StateEnum.ERROR.getCode());

+ 1 - 0
ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/sysdata/services/impl/UpdateDataTableImpl.java

@@ -504,6 +504,7 @@ public class UpdateDataTableImpl extends GenericProvider implements UpdateDataTa
             apiResult.setMessage("参数错误! 必须为select!!!");
             return apiResult;
         }catch (Exception e){
+            e.printStackTrace();
             apiResult.setMessage(e.getMessage());
             apiResult.setState(JcjdConfig.error);
             throw new Exception(JcjdConfig.EXCEPTION);

+ 110 - 103
ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/task/server/CycleTaskServer.java

@@ -1,5 +1,6 @@
 package com.lc.ibps.task.server;
 
+import com.lc.ibps.base.framework.table.ICommonDao;
 import com.lc.ibps.task.services.CycleTaskService;
 import com.lc.ibps.untils.DateUntil;
 import lombok.extern.slf4j.Slf4j;
@@ -7,6 +8,7 @@ import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.util.List;
 
 /***
  *   周期性任务服务
@@ -22,116 +24,121 @@ public class CycleTaskServer {
     @Resource
     private CycleTaskService cycleTaskService;
 
+    @Resource
+    private ICommonDao<?> commonDao;
+
     // 秒   分    时   日   月    周   年(可选)
     // 0    1    1    1    *    ?    *
 
 //    @Scheduled(cron="0 */1 * * * ? ")
 //    public void testTask(){
-//        if (true){
-//            cycleTaskService.startProcess("每日222");
-//        }
+//        log.warn("定时任务每分钟执行开始");
+//        cycleTaskService.startProcess("每日11");
+//        log.warn("定时任务每分钟执行结束");
+//        List<?> list = commonDao.query("select *from t_dsrw where ren_wu_zhuang_tai =#{p0} and ren_wu_zhuang_tai =#{p0} ", new Object[]{"未开始"});
+//        System.out.println("list = " + list);
 //    }
 
-    @Scheduled(cron="0 0 6 * * ?")
-    public void dayTask(){
-        // 每天凌晨6点执行一次
-        log.warn("定时任务凌晨6点执行开始");
-        cycleTaskService.startProcess("每日");
-        log.warn("定时任务凌晨6点执行结束");
-    }
-
-    @Scheduled(cron="0 0 1 ? * MON")
-    public void weekTask(){
-        // 每周执行一次  每个星期一凌晨1点执行
-        log.warn("定时任务每周执行凌晨一点开始");
-        cycleTaskService.startProcess("每周");
-        log.warn("定时任务每周执行凌晨一点结束");
-    }
-
-    //   两周执行一次
-    @Scheduled(cron="0 15 2 ? * MON")
-    public void twoWeekTask(){
-        Integer week= DateUntil.getWeek();
-        if(week%2==0) {
-            //  2周处理
-            log.warn("定时任务每两周执行开始");
-            cycleTaskService.startProcess("每二周");
-            log.warn("定时任务每两周执行结束");
-        }
-    }
-
-    @Scheduled(cron="0 1 1 1 * ?")
-    public void monthTask(){
-        //   每月执行一次  每月一号凌晨1点执行
-        log.warn("定时任务每月执行开始");
-        cycleTaskService.startProcess("每月");
-        log.warn("定时任务每月执行结束");
-    }
-
-    @Scheduled(cron="0 0 0 1 1,4,7,10 ?")
-    public void seasonTask(){
-        // 因为季度周期为3个月,所以可以将月份设置为1/4/7/10
-        // 每季度执行一次   每个季度的1日0点0分执行
-        log.warn("定时任务每季度执行开始");
-        cycleTaskService.startProcess("季度");
-        log.warn("定时任务每季度执行结束");
-    }
-
-    @Scheduled(cron="0 0 0 1 */6 *")
-    public void halfYearTask(){
-        //   每半年执一次
-        log.warn("定时任务每半年执行开始");
-        cycleTaskService.startProcess("每半年");
-        log.warn("定时任务每半年执行结束");
-    }
-
-    @Scheduled(cron="0 0 0 1 1 * ")
-    public void yearTask(){
-        //  每年执一次  每年的1月1日凌晨0点执行
-        log.warn("定时任务每年执行开始");
-        cycleTaskService.startProcess("每年");
-        log.warn("定时任务每年执行结束");
-    }
-
-    @Scheduled(cron="0 0 8 * * ?")
-    public void dailyAt8Am(){
-        //   每日上午8点
-        log.warn("定时任务每日上午8点执行开始");
-        cycleTaskService.startProcess("每日上午8点");
-        log.warn("定时任务每日上午8点执行结束");
-    }
-
-    @Scheduled(cron="0 0 14 * * ?")
-    public void dailyAt2Pm(){
-        //  每日下午2点
-        log.warn("定时任务每日下午2点执行开始");
-        cycleTaskService.startProcess("每日下午2点");
-        log.warn("定时任务每日下午2点执行结束");
-    }
-
-    @Scheduled(cron="0 0 8 ? * MON-FRI")
-    public void weekdaysAt8am(){
-        //  工作日上午8点
-        log.warn("定时任务工作日上午8点执行开始");
-        cycleTaskService.startProcess("工作日上午8点");
-        log.warn("定时任务工作日上午8点执行结束");
-    }
-
-    @Scheduled(cron="0 0 14 ? * MON-FRI")
-    public void weekdaysAt2Pm(){
-        //工作日下午2点
-        log.warn("定时任务工作日下午2点执行开始");
-        cycleTaskService.startProcess("工作日下午2点");
-        log.warn("定时任务工作日下午2点执行结束");
-    }
-
-    @Scheduled(cron="0 0 3 ? * MON-FRI")
-    public void workingDay(){
-        // 工作日3点
-        log.warn("定时任务工作日凌晨3点执行开始");
-        cycleTaskService.startProcess("工作日3点");
-        log.warn("定时任务工作日凌晨3点执行结束");
-    }
+//    @Scheduled(cron="0 0 6 * * ?")
+//    public void dayTask(){
+//        // 每天凌晨6点执行一次
+//        log.warn("定时任务凌晨6点执行开始");
+//        cycleTaskService.startProcess("每日");
+//        log.warn("定时任务凌晨6点执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 1 ? * MON")
+//    public void weekTask(){
+//        // 每周执行一次  每个星期一凌晨1点执行
+//        log.warn("定时任务每周执行凌晨一点开始");
+//        cycleTaskService.startProcess("每周");
+//        log.warn("定时任务每周执行凌晨一点结束");
+//    }
+//
+//    //   两周执行一次
+//    @Scheduled(cron="0 15 2 ? * MON")
+//    public void twoWeekTask(){
+//        Integer week= DateUntil.getWeek();
+//        if(week%2==0) {
+//            //  2周处理
+//            log.warn("定时任务每两周执行开始");
+//            cycleTaskService.startProcess("每二周");
+//            log.warn("定时任务每两周执行结束");
+//        }
+//    }
+//
+//    @Scheduled(cron="0 1 1 1 * ?")
+//    public void monthTask(){
+//        //   每月执行一次  每月一号凌晨1点执行
+//        log.warn("定时任务每月执行开始");
+//        cycleTaskService.startProcess("每月");
+//        log.warn("定时任务每月执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 0 1 1,4,7,10 ?")
+//    public void seasonTask(){
+//        // 因为季度周期为3个月,所以可以将月份设置为1/4/7/10
+//        // 每季度执行一次   每个季度的1日0点0分执行
+//        log.warn("定时任务每季度执行开始");
+//        cycleTaskService.startProcess("季度");
+//        log.warn("定时任务每季度执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 0 1 */6 *")
+//    public void halfYearTask(){
+//        //   每半年执一次
+//        log.warn("定时任务每半年执行开始");
+//        cycleTaskService.startProcess("每半年");
+//        log.warn("定时任务每半年执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 0 1 1 * ")
+//    public void yearTask(){
+//        //  每年执一次  每年的1月1日凌晨0点执行
+//        log.warn("定时任务每年执行开始");
+//        cycleTaskService.startProcess("每年");
+//        log.warn("定时任务每年执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 8 * * ?")
+//    public void dailyAt8Am(){
+//        //   每日上午8点
+//        log.warn("定时任务每日上午8点执行开始");
+//        cycleTaskService.startProcess("每日上午8点");
+//        log.warn("定时任务每日上午8点执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 14 * * ?")
+//    public void dailyAt2Pm(){
+//        //  每日下午2点
+//        log.warn("定时任务每日下午2点执行开始");
+//        cycleTaskService.startProcess("每日下午2点");
+//        log.warn("定时任务每日下午2点执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 8 ? * MON-FRI")
+//    public void weekdaysAt8am(){
+//        //  工作日上午8点
+//        log.warn("定时任务工作日上午8点执行开始");
+//        cycleTaskService.startProcess("工作日上午8点");
+//        log.warn("定时任务工作日上午8点执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 14 ? * MON-FRI")
+//    public void weekdaysAt2Pm(){
+//        //工作日下午2点
+//        log.warn("定时任务工作日下午2点执行开始");
+//        cycleTaskService.startProcess("工作日下午2点");
+//        log.warn("定时任务工作日下午2点执行结束");
+//    }
+//
+//    @Scheduled(cron="0 0 3 ? * MON-FRI")
+//    public void workingDay(){
+//        // 工作日3点
+//        log.warn("定时任务工作日凌晨3点执行开始");
+//        cycleTaskService.startProcess("工作日3点");
+//        log.warn("定时任务工作日凌晨3点执行结束");
+//    }
 
 
 }

+ 1 - 0
ibps-provider-root/modules/provider-platform/src/main/java/com/lc/ibps/platform/plan/job/BasicDataInitializationJob.java

@@ -81,6 +81,7 @@ public class BasicDataInitializationJob extends BaseJob2 {
     private void executeBaseTablesStep(String posAdmin) throws Exception {
         //'Y' means just create one records.   注:所有字段均用大写
         // {"t_dyzzb", "", "N", "岗位职责配置列表"},
+        //  耗材性能验证记录耗材要求配置表  已经修改为单表配置,需要对单个组织架构单独导入
         String[][] tables = {
                 {"t_yjyaylpzb", "t_yjyaylpzzb", "Y", "应急预案演练配置表", "PARENT_ID_" ,""},
                 {"t_gzxybmxzxqkjcjlpzb", "t_gzxybmxzxqkjcjlpzzb", "Y", "公正性与保密性检查项配置表" ,"PARENT_ID_" ,""},

+ 1 - 1
ibps-provider-root/modules/provider-platform/src/main/java/com/lc/ibps/platform/plan/job/EquipmentMaintenancePlanJob.java

@@ -110,7 +110,7 @@ public class EquipmentMaintenancePlanJob  extends AbstractJob {
             Object sheBeiBianHao = i.get("she_bei_bian_hao_");
             if(uk.contains(sheBeiBianHao)){
                 iterator.remove();
-                logger.error(String.format("removed duplicate data %s", sheBeiBianHao));
+                logger.warn(String.format("removed duplicate data %s", sheBeiBianHao));
             }else{
                 uk.add(sheBeiBianHao);
             }