package com.gk.firework.Scheduls.WarningTask;
|
|
import com.gk.firework.Domain.SaleOrderInfo;
|
import com.gk.firework.Domain.WarnContentInfo;
|
import com.gk.firework.Domain.WarningInfo;
|
import com.gk.firework.Service.SaleOrderDetailService;
|
import com.gk.firework.Service.SaleOrderService;
|
import com.gk.firework.Service.WarnContentService;
|
import com.gk.firework.Service.WarningService;
|
import io.swagger.models.auth.In;
|
import org.apache.log4j.LogManager;
|
import org.apache.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import java.io.UnsupportedEncodingException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
@Configuration
|
@EnableScheduling
|
@ConditionalOnProperty(prefix = "scheduling",name = "enabled",havingValue = "true")
|
public class PurchaseWarnTask {
|
private Logger logger = LogManager.getLogger(PurchaseWarnTask.class);
|
private static final String warnType = "购买超量";
|
|
@Autowired
|
WarningService warningService;
|
@Autowired
|
SaleOrderService saleOrderService;
|
@Autowired
|
WarnContentService warnContentService;
|
|
// @Scheduled(cron = "0/5 * * * * ?") //每隔30秒执行一次
|
@Scheduled(cron = "0 0/1 * * * ?") //每隔1分钟执行一次
|
private void purchaseWarn() throws Exception{
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
try {
|
List<WarningInfo> warningInfos = warningService.selectByType(warnType);
|
if (warningInfos.size() > 0){
|
for (WarningInfo warningInfo : warningInfos) {
|
insertWarnContent(warningInfo);
|
}
|
}
|
}catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
private void insertWarnContent(WarningInfo warningInfo) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
Date now = new Date();
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(now);
|
calendar.add(Calendar.DATE, -warningInfo.getPeriod());
|
Date starttime = calendar.getTime();
|
String starttimeStr = sdf.format(starttime);
|
String endttimeStr = sdf.format(now);
|
Integer min = warningInfo.getMinimum();
|
Integer max = warningInfo.getMaximum();
|
//超过预警值
|
List<SaleOrderInfo> earlyWarnList = saleOrderService.selectEarlyWarn(starttimeStr,endttimeStr,min,max);
|
if (earlyWarnList.size() > 0){
|
List<WarnContentInfo> warnContentInfos = new ArrayList<>();
|
for (SaleOrderInfo earlyWarn : earlyWarnList){
|
String warncontent = "超出购买限制,当前购买数量为"+earlyWarn.getBoxnum();
|
WarnContentInfo warnContentExist = warnContentService.selectByWarn(warnType,"预警",earlyWarn.getCustomer(),warncontent);
|
if (warnContentExist == null){
|
WarnContentInfo warnContentInfo = new WarnContentInfo();
|
warnContentInfo.setCustomid(earlyWarn.getCustomer());
|
warnContentInfo.setWarncontent(warncontent);
|
warnContentInfo.setWarntype(warnType);
|
warnContentInfo.setWarnlevel("预警");
|
warnContentInfo.setIsmend((byte) 0);
|
warnContentInfo.setIsneed((byte) 0);
|
warnContentInfo.setIssend((byte) 0);
|
warnContentInfo.setModifiedby("系统生成");
|
warnContentInfo.setModifieddate(new Date());
|
warnContentInfo.setPeriod(warningInfo.getPeriod());
|
warnContentInfo.setCreateddate(new Date());
|
|
if (warnContentInfos.size() > 0){
|
boolean isfound = false;
|
for (WarnContentInfo warnContent : warnContentInfos){
|
if (warnContent.getCustomid().equals(warnContentInfo.getCustomid())
|
&& warnContent.getWarncontent().equals(warnContentInfo.getWarncontent())){
|
isfound = true;
|
break;
|
}
|
}
|
if (!isfound){
|
warnContentInfos.add(warnContentInfo);
|
}
|
}else {
|
warnContentInfos.add(warnContentInfo);
|
}
|
}
|
}
|
warnContentService.saveBatch(warnContentInfos);
|
}
|
|
//超过报警值
|
List<SaleOrderInfo> alarmList = saleOrderService.selectAlarm(starttimeStr,endttimeStr,max);
|
if (alarmList.size() > 0){
|
Byte issms = warningInfo.getIssms();
|
List<WarnContentInfo> warnContentInfos = new ArrayList<>();
|
for (SaleOrderInfo alarm : alarmList){
|
String warncontent = "超出购买限制,当前购买数量为"+alarm.getBoxnum();
|
WarnContentInfo warnContentExist = warnContentService.selectByWarn(warnType,"报警",alarm.getCustomer(),warncontent);
|
if (warnContentExist == null){
|
WarnContentInfo warnContentInfo = new WarnContentInfo();
|
warnContentInfo.setCustomid(alarm.getCustomer());
|
warnContentInfo.setWarncontent(warncontent);
|
warnContentInfo.setWarntype(warnType);
|
warnContentInfo.setWarnlevel("报警");
|
warnContentInfo.setIsmend((byte)0);
|
warnContentInfo.setIsneed(issms);
|
warnContentInfo.setIssend((byte)0);
|
warnContentInfo.setModifiedby("系统生成");
|
warnContentInfo.setModifieddate(new Date());
|
warnContentInfo.setPeriod(warningInfo.getPeriod());
|
warnContentInfo.setCreateddate(new Date());
|
|
if (warnContentInfos.size() > 0){
|
boolean isfound = false;
|
for (WarnContentInfo warnContent : warnContentInfos){
|
if (warnContent.getCustomid().equals(warnContentInfo.getCustomid())
|
&& warnContent.getWarncontent().equals(warnContentInfo.getWarncontent())){
|
isfound = true;
|
break;
|
}
|
}
|
if (!isfound){
|
warnContentInfos.add(warnContentInfo);
|
}
|
}else {
|
warnContentInfos.add(warnContentInfo);
|
}
|
}
|
}
|
|
warnContentService.saveBatch(warnContentInfos);
|
}
|
}
|
|
}
|
