package com.zy.asrs.webSocketConfig;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Arith;
|
import com.core.common.Cools;
|
import com.core.common.R;
|
import com.core.exception.CoolException;
|
import com.zy.asrs.domain.vo.LocChartPie;
|
import com.zy.asrs.entity.*;
|
import com.zy.asrs.domain.dto.WorkChartAxis;
|
import com.zy.asrs.entity.param.MatDto;
|
import com.zy.asrs.mapper.ReportQueryMapper;
|
import com.zy.asrs.service.*;
|
|
import com.zy.common.service.CommonService;
|
import com.zy.common.utils.RedisUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Component
|
@Slf4j
|
public class LedWebsocket {
|
|
private static final String[] WEEK = {"星期日","星期一","星期二","星期三","星期四","星期五","星期六"};
|
|
@Autowired
|
private ReportQueryMapper reportQueryMapper;
|
@Autowired
|
private WebSocketServer webSocketServer;
|
@Autowired
|
private LocDetlService locDetlService;
|
@Autowired
|
private BasDevpService basDevpService;
|
@Autowired
|
private WrkMastService wrkMastService;
|
@Autowired
|
private WrkDetlService wrkDetlService;
|
@Autowired
|
private OrderDetlService orderDetlService;
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Scheduled(cron = "0/2 * * * * ? ")
|
private void send() {
|
|
//饼图
|
List<Map<String, Object>> pie = new ArrayList<>();
|
LocChartPie locUseRate = reportQueryMapper.getLocUseRate();
|
if(locUseRate!=null) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("name", "在库");
|
map.put("value", locUseRate.getFqty());
|
pie.add(map);
|
|
Map<String, Object> map1 = new HashMap<>();
|
map1.put("name", "空");
|
map1.put("value", locUseRate.getOqty());
|
pie.add(map1);
|
|
Map<String, Object> map2 = new HashMap<>();
|
map2.put("name", "使用");
|
map2.put("value", locUseRate.getUqty());
|
pie.add(map2);
|
|
Map<String, Object> map3 = new HashMap<>();
|
map3.put("name", "禁用");
|
map3.put("value", locUseRate.getXqty());
|
pie.add(map3);
|
}
|
// 总库位数
|
Integer total = (int) Arith.add(0, locUseRate.getFqty(), locUseRate.getOqty(), locUseRate.getUqty(), locUseRate.getXqty());
|
// 使用中
|
Integer used = locUseRate.getFqty() + locUseRate.getUqty();
|
// 库位使用率
|
double usedDivides = Arith.divides(3, used, total);
|
double usedPr = Arith.multiplys(1, usedDivides, 100);
|
|
//折线图
|
Map<String,Object> map=new HashMap<String, Object>();
|
List<AxisBean> list = new ArrayList<AxisBean>();
|
List<WorkChartAxis> listChart = reportQueryMapper.getChartAxis();
|
|
if(listChart!=null) {
|
ArrayList<Integer> data1 = new ArrayList<Integer>();
|
ArrayList<Integer> data2 = new ArrayList<Integer>();
|
|
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd");
|
Calendar calendar = Calendar.getInstance();
|
calendar.add(Calendar.DATE, -12);
|
for(int i=0;i<12;i++) {
|
boolean flag = true;
|
calendar.add(Calendar.DATE, 1);
|
String str = sf.format(calendar.getTime());
|
for(WorkChartAxis workChart : listChart) {
|
if(str.equals(workChart.getYmd())) {
|
data1.add(workChart.getInqty());
|
data2.add(workChart.getOutqty());
|
flag = false;
|
break;
|
}
|
}
|
if(flag) {
|
data1.add(0);
|
data2.add(0);
|
}
|
}
|
AxisBean inqty = new AxisBean();
|
inqty.setName("入库数量");
|
Integer[] array1 = new Integer[data1.size()];
|
inqty.setData(data1.toArray(array1));
|
list.add(inqty);
|
AxisBean outqty = new AxisBean();
|
outqty.setName("出库数量");
|
Integer[] array2 = new Integer[data2.size()];
|
outqty.setData(data2.toArray(array2));
|
list.add(outqty);
|
}
|
//仓库数据
|
EntityWrapper<LocDetl> locDetlEntityWrapper = new EntityWrapper<>();
|
locDetlEntityWrapper.setSqlSelect("TOP 5 matnr,SUM(anfme) as matnrCount").groupBy("matnr").orderBy("matnrCount",false);
|
List<Map<String, Object>> selectMap = locDetlService.selectMaps(locDetlEntityWrapper);
|
|
Date now = new Date();
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(now);
|
// Map<String, Object> map = new HashMap<>();
|
map.put("to","all");
|
map.put("message", Cools.add("type", "default").add("pie", pie)
|
.add("stockCunt", locUseRate.getFqty())
|
.add("emptyCount", locUseRate.getOqty())
|
.add("noneCount", locUseRate.getXqty())
|
.add("total", total)
|
.add("used", used)
|
.add("usedPr", usedPr)
|
.add("rows",list)
|
.add("year", calendar.get(Calendar.YEAR))
|
.add("month", CommonService.zerofill(String.valueOf(calendar.get(Calendar.MONTH)+1), 2))
|
.add("day", CommonService.zerofill(String.valueOf(calendar.get(Calendar.DATE)), 2))
|
.add("hour", CommonService.zerofill(String.valueOf(calendar.get(Calendar.HOUR_OF_DAY)), 2))
|
.add("minute", CommonService.zerofill(String.valueOf(calendar.get(Calendar.MINUTE)), 2))
|
.add("second", CommonService.zerofill(String.valueOf(calendar.get(Calendar.SECOND)) , 2))
|
.add("week", WEEK[calendar.get(Calendar.DAY_OF_WEEK)-1])
|
.add("inventoryData",selectMap));
|
webSocketServer.onMessage(JSONObject.toJSONString(map),null,"all");
|
|
}
|
|
@Scheduled(cron = "0/2 * * * * ? ")
|
private void ErrorSend(){
|
Map<String,Object> map=new HashMap<>();
|
map.put("to","1002");
|
BasDevp basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no", 1002));
|
if (basDevp == null ){
|
return;
|
}
|
String key = "wms_websocket_error";
|
Object object = redisUtil.get(key);
|
if (null != object && object.equals(basDevp.getDecDesc())){
|
return;
|
}
|
map.put("message",Cools.add("type", "error").add("errMsg",basDevp.getDecDesc()));
|
webSocketServer.onMessage(JSONObject.toJSONString(map),null,"1002");
|
redisUtil.set(key,basDevp.getDecDesc(),15);
|
}
|
|
|
@Scheduled(cron = "0/2 * * * * ? ")
|
private void TaskSend(){
|
Map<String,Object> map=new HashMap<>();
|
map.put("to","1002");
|
BasDevp basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no", 1002));
|
if (basDevp == null ){
|
return;
|
}
|
String key = "wms_websocket_task";
|
Object object = redisUtil.get(key);
|
if (null != object && object.equals(basDevp.getWrkNo())){
|
return;
|
}
|
List<LedCommand> commandList = new ArrayList<>();
|
if (basDevp.getWrkNo() != 0){
|
WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo()));
|
if (null != wrkMast){
|
commandList = getCommandList(basDevp.getWrkNo().toString());
|
}
|
}
|
map.put("message",Cools.add("type", "task").add("taskList",commandList));
|
webSocketServer.onMessage(JSONObject.toJSONString(map),null,"1002");
|
redisUtil.set(key,basDevp.getWrkNo(),15);
|
}
|
|
public List<LedCommand> getCommandList(String taskNo){
|
List<LedCommand> commands = new ArrayList<>();
|
// 工作档集合
|
List<WrkMast> wrkMasts = new ArrayList<>();
|
// 获取工作档数据
|
WrkMast wrkMast = wrkMastService.selectById(taskNo);
|
if (null == wrkMast) { return null; }
|
wrkMasts.add(wrkMast);
|
// 组装命令
|
LedCommand ledCommand = new LedCommand();
|
ledCommand.setWorkNo(wrkMast.getWrkNo());
|
ledCommand.setIoType(wrkMast.getIoType());
|
wrkMasts.add(wrkMast);
|
// 出库模式
|
switch (wrkMast.getIoType()) {
|
case 1:
|
ledCommand.setTitle("全板入库");
|
break;
|
case 10:
|
ledCommand.setTitle("空板入库");
|
break;
|
case 101:
|
ledCommand.setTitle("全板出库");
|
break;
|
case 103:
|
ledCommand.setTitle("拣料出库");
|
break;
|
case 104:
|
ledCommand.setTitle("并板出库");
|
break;
|
case 107:
|
ledCommand.setTitle("盘点出库");
|
break;
|
case 110:
|
ledCommand.setTitle("空板出库");
|
ledCommand.setEmptyMk(true);
|
break;
|
default:
|
break;
|
}
|
ledCommand.setSourceLocNo(wrkMast.getSourceLocNo());
|
ledCommand.setStaNo(wrkMast.getStaNo());
|
ledCommand.setBarcode(wrkMast.getBarcode());
|
if (wrkMast.getIoType() != 110 && wrkMast.getIoType() != 10) {
|
List<WrkDetl> wrkDetls = wrkDetlService.findByWorkNo(wrkMast.getWrkNo());
|
|
wrkDetls.forEach(wrkDetl -> {
|
Double total = 0.0;
|
EntityWrapper<LocDetl> wrapper = new EntityWrapper<>();
|
LocDetl locDetl = locDetlService.selectOne(wrapper.eq("zpallet", wrkDetl.getZpallet()).eq("matnr", wrkDetl.getMatnr()));
|
if (Cools.isEmpty(locDetl)) {
|
total = wrkDetl.getAnfme();
|
} else {
|
total = locDetl.getAnfme();
|
}
|
if (!Cools.isEmpty(wrkDetl.getOrderNo())){
|
OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", wrkDetl.getOrderNo())
|
.eq("matnr", wrkDetl.getMatnr()).eq("batch", wrkDetl.getBatch()));
|
if (wrkMast.getIoType() == 101 || wrkMast.getIoType() == 1) {
|
ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total,orderDetl.getSuppCode(),orderDetl.getSku()));
|
}
|
if (wrkMast.getIoType() == 103 && (null == wrkDetl.getInspect() || 0 == wrkDetl.getInspect())) {
|
ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total,orderDetl.getSuppCode(),orderDetl.getSku()));
|
}
|
if (wrkMast.getIoType() == 107 || wrkMast.getIoType() == 104) {
|
ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total,orderDetl.getSuppCode(),orderDetl.getSku()));
|
}
|
}else {
|
if (wrkMast.getIoType() == 101 || wrkMast.getIoType() == 1) {
|
ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
|
}
|
if (wrkMast.getIoType() == 103 && (null == wrkDetl.getInspect() || 0 == wrkDetl.getInspect())) {
|
ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
|
}
|
if (wrkMast.getIoType() == 107 || wrkMast.getIoType() == 104) {
|
ledCommand.getMatDtos().add(new MatDto(wrkDetl.getMatnr(), wrkDetl.getMaktx(), wrkDetl.getBatch(), wrkDetl.getSpecs(), wrkDetl.getManu(), wrkDetl.getMemo(), wrkDetl.getAnfme(),total));
|
}
|
}
|
});
|
}
|
commands.add(ledCommand);
|
|
Set<Integer> workNos = wrkMasts.stream().map(WrkMast::getWrkNo).collect(Collectors.toSet());
|
// 修改主档led标记
|
for (WrkMast wrkMast1 : wrkMasts) {
|
wrkMast1.setOveMk("Y");
|
wrkMast1.setModiTime(new Date());
|
if (!wrkMastService.update(wrkMast1,new EntityWrapper<WrkMast>().eq("wrk_No",wrkMast1.getWrkNo()))) {
|
throw new CoolException("更新工作档失败");
|
}
|
}
|
|
return commands;
|
}
|
}
|
