package com.ld.igds.warn;
|
|
import com.bstek.bdf2.core.model.DefaultUser;
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.common.mapper.CommonMapper;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.constant.WarnLevel;
|
import com.ld.igds.constant.WarnStatus;
|
import com.ld.igds.constant.WarnType;
|
import com.ld.igds.models.Depot;
|
import com.ld.igds.models.DepotConf;
|
import com.ld.igds.models.Grain;
|
import com.ld.igds.models.MWarnConf;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.warn.data.WarnData;
|
import com.ld.igds.warn.service.CoreWarnService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.time.DateFormatUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* 警告工具类
|
*
|
* @author: chen
|
* @description:
|
* @version:
|
* @data:2021年12月06日
|
*/
|
@Service(WarnUtils.BEAN_ID)
|
@Slf4j
|
public class WarnUtils {
|
|
public static final String BEAN_ID = "core.warnUtils";
|
|
//出入库推送微信接口编码
|
public static final String WECHAT_WARN_1007 = "1007";
|
//警告推送微信接口编码
|
public static final String WECHAT_WARN_1008 = "1008";
|
//工单推送微信接口
|
public static final String WECHAT_WARN_1011 = "1011";
|
|
@Autowired
|
private CoreCommonService commonService;
|
@Autowired
|
private CoreWarnService coreWarnService;
|
@Autowired
|
private CommonMapper commonMapper;
|
|
/**
|
* 根据警告配置获取通知人
|
*
|
* @param conf
|
* @return
|
*/
|
public List<DefaultUser> getWarnUserByWarnConf(MWarnConf conf, String depotId) {
|
if(null == conf){
|
return null;
|
}
|
|
//获取仓库信息，用于下面获取保管员
|
Depot depot = commonService.getCacheDepot(conf.getCompanyId(), depotId);
|
|
// 根据警告配置获取通知人
|
List<String> listUser = new ArrayList<>();
|
if (StringUtils.isNotEmpty(conf.getUser1())) listUser.add(conf.getUser1());
|
if (StringUtils.isNotEmpty(conf.getUser2())) listUser.add(conf.getUser2());
|
if (StringUtils.isNotEmpty(conf.getUser3())) listUser.add(conf.getUser3());
|
if (StringUtils.isNotEmpty(conf.getUser4())) listUser.add(conf.getUser4());
|
if (StringUtils.isNotEmpty(conf.getUser5())) listUser.add(conf.getUser5());
|
if (null !=depot && Constant.YN_Y.equals(conf.getKeeperTag())
|
&& StringUtils.isNotEmpty(depot.getStoreKeeper())){
|
listUser.add(depot.getStoreKeeper());
|
}
|
|
return commonMapper.getUserByList(conf.getCompanyId(), listUser);
|
}
|
|
/**
|
* 设置微信通知人等信息
|
* @param warnData
|
* @param users
|
* @return
|
*/
|
public WarnData setPhoneByWeChat(WarnData warnData, List<DefaultUser> users) {
|
if (users.size() > 0) {
|
warnData.setNoticeUser("");
|
warnData.setPhone("");
|
for (DefaultUser defaultUser : users) {
|
if (StringUtils.isEmpty(defaultUser.getMobile())){
|
continue;
|
}
|
warnData.setNoticeUser(defaultUser.getUsername() + "," + warnData.getNoticeUser());
|
warnData.setPhone(defaultUser.getMobile() + "," + warnData.getPhone());
|
}
|
}
|
return warnData;
|
}
|
|
/**
|
* 增加粮情高温记录
|
* @param depotConf
|
* @param grain
|
*/
|
public void addGrainWarn(DepotConf depotConf, Grain grain){
|
//获取仓库信息
|
Depot depot = commonService.getCacheDepot(depotConf.getCompanyId(), depotConf.getDepotId());
|
if(null == depot){
|
log.error("-----未获取到仓库信息，不生成警告-----");
|
return;
|
}
|
WarnData warn = new WarnData();
|
warn.setId(ContextUtil.getUUID());
|
warn.setCompanyId(depot.getCompanyId());
|
warn.setDeptId(depot.getDeptId());
|
warn.setDepotId(depot.getId());
|
warn.setDepotName(depot.getName());
|
|
warn.setName("粮情高温警告");
|
warn.setType(WarnType.TYPE_01.getCode());
|
warn.setLevel(WarnLevel.LEVEL_01.getCode());
|
warn.setTime(grain.getReceiveDate());
|
warn.setBizType(Constant.MODEL_GRAIN);
|
warn.setStatus(WarnStatus.STATUS_10.getCode());
|
|
String info = depot.getName() + "出现粮情高温警告，设定高温：" + depotConf.getTempMax()
|
+ "， 当前检测高温：" + grain.getTempMax() + "，检测时间：" +
|
DateFormatUtils.format(grain.getReceiveDate(),"yyyy-MM-dd HH:mm:ss");
|
warn.setInfo(info);
|
|
coreWarnService.addWarnAndNotice(warn);
|
}
|
}
|
