高危号码上报蓝紫名单

tnc-sms/src/main/java/org/jeecg/modules/smscheck/controller/BusinessReminderCardController.java

@@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -109,6 +110,7 @@ public class BusinessReminderCardController  extends JeecgController<BusinessRem
         String upTimeStart = request.getParameterMap().get("upTimeStart")==null?"":Arrays.toString(request.getParameterMap().get("upTimeStart")).replace("[", "").replace("]", "").replace("*", "");
         String upTimeEnd = request.getParameterMap().get("upTimeEnd")==null?"":Arrays.toString(request.getParameterMap().get("upTimeEnd")).replace("[", "").replace("]", "").replace("*", "");
 
+        List<String> selectLanOrZi = request.getParameterMap().get("selectLanOrZi[]")==null?new ArrayList<>():  new ArrayList<>(Arrays.asList(request.getParameterMap().get("selectLanOrZi[]")));
 
         businessReminderCard.setDelFlag( CommonConstant.DEL_FLAG_0);
         String numberResults_MultiString = request.getParameterMap().get("numberResults_MultiString")==null?"":
@@ -161,6 +163,28 @@ public class BusinessReminderCardController  extends JeecgController<BusinessRem
         if (StringUtils.isNotBlank(numberResults_MultiString)){
             queryWrapper.like("number_results",numberResults_MultiString);
         }
+
+        if (!CollectionUtils.isEmpty(selectLanOrZi)){
+
+            queryWrapper.and(wrapper -> {
+                for (String s : selectLanOrZi) {
+                    if (s.equals("3,4")){
+                        wrapper.eq("number_results","3,4")
+                                .or();
+                        wrapper.eq("number_results","4,3");
+                    }else if (s.equals("0")){
+                        wrapper.eq("number_results","1")
+                                .or();
+                        wrapper.eq("number_results","0");
+                    }else {
+                        wrapper.eq("number_results",s)
+                                .or();
+                    }
+                }
+            });
+
+        }
+
         if (numberResults.size()!=0){
             List<Integer> collect = numberResults.stream().map(Integer::valueOf)
                     .collect(Collectors.toList());

tnc-sms/src/main/java/org/jeecg/modules/smscheck/controller/TncEnableScheduling.java

@@ -0,0 +1,69 @@
+package org.jeecg.modules.smscheck.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.jeecg.modules.smscheck.configs.CheckStateCode;
+import org.jeecg.modules.smscheck.entity.BusinessReminderCard;
+import org.jeecg.modules.smscheck.entity.SmsCheckCustomerInfoBecomeDue;
+import org.jeecg.modules.smscheck.service.BusinessReminderCardService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+
+@RestController
+@Slf4j
+@RequestMapping("/tncEnableScheduling")
+public class TncEnableScheduling {
+
+
+
+    @Autowired
+    private BusinessReminderCardService businessReminderCardService;
+
+
+
+    @Scheduled(cron = "0 * * * * ?")
+    @ResponseBody
+    public void tncEnableScheduling(){
+        log.info("tncEnableScheduling 开始启动");
+        List<String> numberResults =new ArrayList<>(Arrays.asList("3","4"));
+        //上报蓝名单 3
+        //上报紫名单 4
+        //非高危 1
+        //上报关停 2
+        LambdaQueryWrapper<BusinessReminderCard> query = new LambdaQueryWrapper<>();
+        query.and(wrapper -> {
+            wrapper.eq(BusinessReminderCard::getNumberResults,"3")
+                    .or()
+                    .eq(BusinessReminderCard::getNumberResults,"4")
+                    .or()
+                    .eq(BusinessReminderCard::getNumberResults,"3,4")
+                    .or()
+                    .eq(BusinessReminderCard::getNumberResults,"4,3");
+        });
+        query.eq(BusinessReminderCard::getStatus,"0");
+
+        query.lt(BusinessReminderCard::getCreateTime, LocalDateTime.now().minusHours(48));
+
+        List<BusinessReminderCard> list = businessReminderCardService.list(query);
+        for (BusinessReminderCard businessReminderCard : list) {
+            UpdateWrapper<BusinessReminderCard> updateWrapper = new UpdateWrapper<>();
+            updateWrapper.eq("id", businessReminderCard.getId()).set("status", "1").set("update_time",new Date());
+            businessReminderCardService.update(updateWrapper);
+            log.info("tncEnableScheduling  更新成功:{}",businessReminderCard.getId());
+        }
+        log.info("tncEnableScheduling结束");
+    }
+
+}

tnc-system/src/main/java/org/jeecg/TncSystemApplication.java

@@ -9,6 +9,7 @@ import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.core.env.Environment;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 import java.io.*;
 import java.net.InetAddress;
@@ -23,6 +24,7 @@ import java.util.PropertyResourceBundle;
  */
 @Slf4j
 @SpringBootApplication(exclude={MongoAutoConfiguration.class})
+@EnableScheduling
 public class TncSystemApplication extends SpringBootServletInitializer {
 
     @Override