From c2fccb01b972176dc3da5a497b5e904025e9e98d Mon Sep 17 00:00:00 2001
From: bsw215583320 <baoshiwei121@163.com>
Date: 星期二, 16 四月 2024 15:06:51 +0800
Subject: [PATCH] Merge branch 'master' of http://210.22.126.130:1111/r/dry/herb
---
jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java | 422 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 422 insertions(+), 0 deletions(-)
diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
new file mode 100644
index 0000000..aa8d0f9
--- /dev/null
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryRealTimeDataServiceImpl.java
@@ -0,0 +1,422 @@
+package org.jeecg.modules.dry.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.mina.core.service.IoAcceptor;
+import org.apache.mina.core.service.IoHandler;
+import org.apache.mina.core.session.IoSession;
+import org.jeecg.common.api.CommonAPI;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.config.TenantContext;
+import org.jeecg.common.config.mqtoken.UserTokenContext;
+import org.jeecg.common.constant.CommonConstant;
+import org.jeecg.common.system.util.JwtUtil;
+import org.jeecg.common.util.RedisUtil;
+import org.jeecg.common.util.SpringContextUtils;
+import org.jeecg.modules.dry.common.CacheConstants;
+import org.jeecg.modules.dry.entity.*;
+import org.jeecg.modules.dry.service.*;
+import org.jeecg.modules.dry.socket.ServerHandler;
+import org.jeecg.modules.dry.socket.SocketServerConfig;
+import org.jeecg.modules.dry.util.DryUtil;
+import org.jeecg.modules.dry.vo.*;
+import org.jetbrains.annotations.NotNull;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.io.IOException;
+import java.io.ObjectOutputStream;
+import java.net.Socket;
+import java.text.DecimalFormat;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+@Slf4j
+@Service
+public class DryRealTimeDataServiceImpl implements IDryRealTimeDataService {
+ @Autowired
+ private IDryOrderService dryOrderService;
+ @Autowired
+ private IDryOrderTrendService dryOrderTrendService;
+
+ @Autowired
+ private IDryHerbService herbService;
+
+ @Autowired
+ private IDryEquipmentService equipmentService;
+
+ @Autowired
+ private RedisUtil redisUtil;
+
+ @Autowired
+ private IDryProdRecordService prodRecordService;
+
+ @Autowired
+ private CommonAPI commonAPI;
+
+ private String token;
+
+
+
+ public String getTemporaryToken() {
+ if (token == null) {
+ RedisUtil redisUtil = SpringContextUtils.getBean(RedisUtil.class);
+ // 妯℃嫙鐧诲綍鐢熸垚Token
+ token = JwtUtil.sign("admin", "b668043e3ea4bc2d");
+ // 璁剧疆Token缂撳瓨鏈夋晥鏃堕棿涓� 5 鍒嗛挓
+ redisUtil.set(CommonConstant.PREFIX_USER_TOKEN + token, token);
+ redisUtil.expire(CommonConstant.PREFIX_USER_TOKEN + token, 5 * 60 * 1000);
+ }
+
+ return token;
+ }
+
+ @Override
+ @Transactional
+ public Result<?> realTimeDataHandle(RealTimeDataVo realTimeDataVo) {
+ TenantContext.setTenant(realTimeDataVo.getTenantid()+"");
+ // log.info("瀹炴椂鏁版嵁锛�"+realTimeDataVo.toString());
+
+
+ // 1 鏌ヨ鎴栧垱寤哄伐鍗�
+ // 1.1 浠巖edis鍙栧嚭宸ュ崟缂撳瓨
+ DryOrderVo orderVo = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(),
+ realTimeDataVo.getTenantid()+"_"+realTimeDataVo.getMachineid());
+ // 1.2 濡傛灉鏈夌紦瀛樿褰�
+ if(orderVo != null && orderVo.getCode().equals(realTimeDataVo.getWorkorder())) {
+
+ // 1.3 娌℃湁缂撳瓨璁板綍鍐嶆煡璇㈡暟鎹簱
+ } else {
+ // 鏍规嵁绉熸埛id鍜屽伐鍗曞彿鏌ヨ鏁版嵁搴撴槸鍚︽湁璁板綍锛屾湁鍒欒繑鍥烇紝娌℃湁鍒欐柊澧炰竴鏉″啀杩斿洖
+ orderVo = getOrSaveDryOrderVoDB(realTimeDataVo);
+ }
+
+ // 2 鏇存柊宸ュ崟瀹炴椂鏁版嵁
+ // 2.1 灏嗗伐鍗曚腑鐨勬暟鎹浛鎹负鏈�鏂版暟鎹�
+ realTimeDataVo.setOrderId(orderVo.getId());
+ orderVo.setInitial(realTimeDataVo.getMoisture1());
+ orderVo.setDryTime(realTimeDataVo.getTime3());
+ orderVo.setDelay(realTimeDataVo.getDelay());
+ orderVo.setTurn(realTimeDataVo.getTurntime());
+ orderVo.setYield(realTimeDataVo.getWeight3());
+ orderVo.setStart(realTimeDataVo.getStart());
+ orderVo.setAuto(realTimeDataVo.getAuto());
+ orderVo.setPlcdisable(realTimeDataVo.getPlcdisable());
+ orderVo.setLowalarm(realTimeDataVo.getLowalarm());
+ orderVo.setWind(realTimeDataVo.getWind());
+ orderVo.setOriginWeight(realTimeDataVo.getWeight2());
+ orderVo.setWatt(realTimeDataVo.getWatt());
+ orderVo.setSteam(realTimeDataVo.getSteam());
+ orderVo.setEnvHum(realTimeDataVo.getEnvhum());
+ orderVo.setEnvTemp(realTimeDataVo.getEnvtemp());
+ orderVo.setRemain(realTimeDataVo.getAi_total_time());
+ orderVo.setCurRemain(realTimeDataVo.getAi_time());
+ orderVo.setState_fan(realTimeDataVo.getState_fan());
+ orderVo.setState_roller(realTimeDataVo.getState_roller());
+ orderVo.setState_auto(realTimeDataVo.getState_auto());
+ orderVo.setState_windbox(realTimeDataVo.getState_windbox());
+ orderVo.setState_valve(realTimeDataVo.getState_valve());
+ orderVo.setOrderStatus(realTimeDataVo.getWorkorder_status());
+ orderVo.setEqp_status(realTimeDataVo.getEqp_status());
+ orderVo.setEqp_state(realTimeDataVo.getEqp_state());
+ orderVo.setWarning(realTimeDataVo.getEqp_warning());
+ orderVo.setFault(realTimeDataVo.getEqp_fault());
+ orderVo.setLevel(realTimeDataVo.getLevel());
+
+
+ DryOrderTrendVo trendVo = new DryOrderTrendVo(realTimeDataVo);
+ // 2.2 淇濆瓨宸ュ崟鍚按鐜囧彉鍖� 鎴� 閲嶉噺鍙樺寲
+
+ if(realTimeDataVo.getReport_flag()) {
+ DryProdRecord prodRecord = new DryProdRecord();
+ prodRecord.setReportHeadName(realTimeDataVo.getReport_head_name());
+ prodRecord.setReportHeadBatch(realTimeDataVo.getReport_head_batch());
+ prodRecord.setReportHeadNum(realTimeDataVo.getReport_head_num());
+ prodRecord.setReportHeadMachine(realTimeDataVo.getReport_head_machine());
+ prodRecord.setReportHeadAccepter(realTimeDataVo.getReport_head_accepter());
+ prodRecord.setReportHeadDate(realTimeDataVo.getReport_head_date());
+ prodRecord.setReportHeadLeader(realTimeDataVo.getReport_head_leader());
+ prodRecord.setReportHeadTecher(realTimeDataVo.getReport_head_techer());
+
+ prodRecord.setReportCheckField(realTimeDataVo.getReport_check_field()?1:0);
+ prodRecord.setReportCheckFile(realTimeDataVo.getReport_check_file()?1:0);
+ prodRecord.setReportCheckTag(realTimeDataVo.getReport_check_tag()?1:0);
+ prodRecord.setReportCheckTool(realTimeDataVo.getReport_check_tool()?1:0);
+ prodRecord.setReportCheckMan(realTimeDataVo.getReport_check_man());
+ prodRecord.setReportCheckStatus(realTimeDataVo.getReport_check_status()?1:0);
+ prodRecord.setReportCheckQa(realTimeDataVo.getReport_check_qa());
+ prodRecord.setReportCheckRecord(realTimeDataVo.getReport_check_record());
+
+ prodRecord.setReportProductView(realTimeDataVo.getReport_product_view()?1:0);
+ prodRecord.setReportProductWind(realTimeDataVo.getReport_product_wind()?1:0);
+ prodRecord.setReportProductSun(realTimeDataVo.getReport_product_sun()?1:0);
+ prodRecord.setReportProductLowDry(realTimeDataVo.getReport_product_low_dry()?1:0);
+ prodRecord.setReportProductDry(realTimeDataVo.getReport_product_dry()?1:0);
+ prodRecord.setReportProductStart(realTimeDataVo.getReport_product_start());
+ prodRecord.setReportProductEnd(realTimeDataVo.getReport_product_end());
+ prodRecord.setReportProductTotal(realTimeDataVo.getReport_product_total());
+ prodRecord.setReportProductCheck(realTimeDataVo.getReport_product_check()?1:0);
+ prodRecord.setReportProductMan1(realTimeDataVo.getReport_product_man1());
+ prodRecord.setReportProductMan2(realTimeDataVo.getReport_product_man2());
+ prodRecord.setReportProductWeight(realTimeDataVo.getReport_product_weight());
+ prodRecord.setReportProductWaste(realTimeDataVo.getReport_product_waste());
+ prodRecord.setReportProductUse(realTimeDataVo.getReport_product_use());
+ prodRecord.setReportProductQa(realTimeDataVo.getReport_product_qa());
+
+ prodRecord.setReportCleanMachine(realTimeDataVo.getReport_clean_machine()?1:0);
+ prodRecord.setReportCleanWaste(realTimeDataVo.getReport_clean_waste()?1:0);
+ prodRecord.setReportCleanTool(realTimeDataVo.getReport_clean_tool()?1:0);
+ prodRecord.setReportCleanDoor(realTimeDataVo.getReport_clean_door()?1:0);
+ prodRecord.setReportCleanBox(realTimeDataVo.getReport_clean_box()?1:0);
+ prodRecord.setReportCleanRecord(realTimeDataVo.getReport_clean_record()?1:0);
+ prodRecord.setReportCleanDate(realTimeDataVo.getReport_clean_date());
+ prodRecord.setReportCleanMan(realTimeDataVo.getReport_clean_man());
+ prodRecord.setReportCleanConfirm(realTimeDataVo.getReport_clean_confirm()?1:0);
+ prodRecord.setReportCleanQa(realTimeDataVo.getReport_clean_qa());
+ prodRecordService.save(prodRecord);
+ }
+ saveOrderTrendVo(trendVo, orderVo);
+ orderVo.setTrendVo(trendVo);
+ orderVo.getBellowsTemp().put(realTimeDataVo.getTime3(), realTimeDataVo.getTemp2());
+ // 2.3 鏇存柊鍒皉edis缂撳瓨
+ redisUtil.hset(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(),
+ realTimeDataVo.getTenantid()+"_"+realTimeDataVo.getMachineid(),orderVo, 600000);
+ return Result.ok();
+ }
+
+ /**
+ * 鏍规嵁绉熸埛id鍜屽伐鍗曞彿鏌ヨ鏁版嵁搴撴槸鍚︽湁璁板綍锛屾湁鍒欒繑鍥烇紝娌℃湁鍒欐柊澧炰竴鏉�
+ * @param realTimeDataVo
+ * @return
+ */
+ private DryOrderVo getOrSaveDryOrderVoDB(RealTimeDataVo realTimeDataVo) {
+ DryOrderVo orderVo;
+ LambdaQueryWrapper<DryOrder> queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(DryOrder::getCode, realTimeDataVo.getWorkorder());
+ queryWrapper.eq(DryOrder::getTenantId, realTimeDataVo.getTenantid());
+ // 1 鏌ヨ鏁版嵁搴�
+ DryOrder one = dryOrderService.getOne(queryWrapper);
+ // 2 鏁版嵁搴撴湁璁板綍锛屾洿鏂板埌缂撳瓨
+ if (one != null) {
+ // 杞崲涓虹紦瀛樻暟鎹粨鏋�
+ orderVo = BeanUtil.toBean(one, DryOrderVo.class);
+ if (one.getTemps() != null) {
+ Map map = JSONObject.parseObject(one.getTemps(), new TypeReference<Map<Integer,Double>>(){});
+ orderVo.setBellowsTemp(map);
+ }
+ // 鏌ヨ绉伴噸璁板綍锛屾坊鍔犲埌缂撳瓨鏁版嵁缁撴瀯
+ List<DryOrderTrendVo> trendVos = dryOrderTrendService.listByOrderId(one.getId());
+ if (trendVos != null && trendVos.size() > 0) {
+ DryOrderTrendVo oldVo = trendVos.get(trendVos.size() - 1);
+ orderVo.setTrendVo(oldVo);
+ orderVo.setDetailList(trendVos);
+ }
+ // 3 鏁版嵁搴撴病鏈夊垯鏂板涓�鏉℃暟鎹�
+ } else {
+ orderVo = saveNewOrder(realTimeDataVo);
+ }
+ return orderVo;
+ }
+
+ /**
+ * 淇濆瓨鏂板伐鍗�
+ * @param realTimeDataVo
+ * @return
+ */
+ @NotNull
+ private DryOrderVo saveNewOrder(RealTimeDataVo realTimeDataVo) {
+ DryOrderVo orderVo;
+ // 鏌ヨ鑽潗
+ DryHerb herb = queryHerbByIndexTenant(realTimeDataVo);
+ // 鏌ヨ璁惧
+ DryEquipment equ = queryEquipmentByCodeTenant(realTimeDataVo);
+
+ // 鍒涘缓鏂板伐鍗�
+ orderVo = new DryOrderVo(realTimeDataVo);
+ orderVo.setHerbId(herb.getId());
+ orderVo.setEquId(equ.getId());
+ DryOrder dryOrder = BeanUtil.toBean(orderVo, DryOrder.class);
+ boolean save = dryOrderService.save(dryOrder);
+ return orderVo;
+ }
+
+
+ /**
+ * 鏌ヨ璁惧锛屾柊璁惧鍒欐坊鍔犲埌璁惧涓绘暟鎹�
+ * @param realTimeDataVo
+ * @return
+ */
+ private DryEquipment queryEquipmentByCodeTenant(RealTimeDataVo realTimeDataVo) {
+ LambdaQueryWrapper<DryEquipment> queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(DryEquipment::getTenantId, realTimeDataVo.getTenantid());
+ queryWrapper.eq(DryEquipment::getCode, realTimeDataVo.getMachineid());
+ DryEquipment one = equipmentService.getOne(queryWrapper);
+ if (one == null) {
+ one = new DryEquipment(realTimeDataVo);
+ equipmentService.save(one);
+ }
+ return one;
+ }
+
+ /**
+ * 鏌ヨ鑽潗锛屾柊鑽潗娣诲姞鍒版暟鎹簱
+ * @param realTimeDataVo
+ * @return
+ */
+ private DryHerb queryHerbByIndexTenant(RealTimeDataVo realTimeDataVo) {
+ LambdaQueryWrapper<DryHerb> queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(DryHerb::getTenantId, realTimeDataVo.getTenantid());
+ queryWrapper.eq(DryHerb::getCode, realTimeDataVo.getIndex());
+ DryHerb one = herbService.getOne(queryWrapper);
+ if (one == null) {
+ one = new DryHerb(realTimeDataVo);
+ herbService.save(one);
+ }
+ return one;
+ }
+
+ /**
+ * 淇濆瓨鍚按鐜囧彉鍖栬褰�
+ * @param trendVo
+ * @param orderVo
+ */
+ private void saveOrderTrendVo(DryOrderTrendVo trendVo, DryOrderVo orderVo) {
+ //鍒ゆ柇 瀹炴椂鍚按鐜� 鎴� 瀹炴椂閲嶉噺鏈夋病鏈夊彉鍖栵紝鏈夊彉鍖栧垯鏇存柊
+ if(orderVo.getTrendVo() == null
+ || trendVo.getWeight() < orderVo.getTrendVo().getWeight()
+ ) {
+ DryOrder byId = dryOrderService.getById(orderVo.getId());
+ // 灏嗘渶鏂扮粨鏋滄洿鏂板埌宸ュ崟
+ if (byId != null) {
+ BeanUtil.copyProperties(orderVo, byId);
+ byId.setTemps(JSONObject.toJSONString(orderVo.getBellowsTemp()));
+ dryOrderService.updateById(byId);
+ }
+ // 淇濆瓨鍚按鐜囧彉鍖�
+ orderVo.getDetailList().add(trendVo);
+ DryOrderTrend dryOrderTrend = BeanUtil.toBean(trendVo, DryOrderTrend.class);
+ dryOrderTrendService.save(dryOrderTrend);
+ }
+ }
+
+
+ /**
+ * 鏌ヨ鏈哄彴瀹炴椂鏁版嵁
+ * @param realTimeDataVo
+ * @return
+ */
+ @Override
+ public Result<?> queryMachineRealTImeData(RealTimeDataVo realTimeDataVo) {
+ TenantContext.setTenant(realTimeDataVo.getTenantid()+"");
+
+
+ LambdaQueryWrapper<DryEquipment> queryWrapper = new LambdaQueryWrapper<>();
+
+ queryWrapper.eq(DryEquipment::getTenantId, realTimeDataVo.getTenantid());
+ queryWrapper.eq(DryEquipment::getEnable, "Y");
+
+ List<DryEquipment> dryEquipments = equipmentService.list(queryWrapper);
+ List<String> list = new ArrayList<>();
+
+ List<Double> dList = new ArrayList<>();
+ DryOrderVo orderVo = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + realTimeDataVo.getMachineid());
+ try {
+
+
+ if (dryEquipments != null && dryEquipments.size() > 0) {
+ dryEquipments.stream().forEach(item -> {
+ DryOrderVo order = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + item.getCode());
+ if (order != null) {
+ double v = order.getOriginWeight() - order.getYield();
+ list.add(item.getName().substring(0, item.getName().indexOf('#')+1));
+ if (v > 0 && order.getDryTime()>0) {
+ DecimalFormat df = new DecimalFormat("#.00");
+ dList.add(Double.valueOf(df.format(v / order.getDryTime() * 60)));
+ } else {
+ dList.add(50d);
+ }
+
+ }
+ });
+ }
+ if (orderVo != null) {
+ orderVo.setCompEqpNum(list);
+ orderVo.setCompEqpEffic(dList);
+ }
+ }catch (Exception e) {
+ e.printStackTrace();
+ }
+ return Result.ok(orderVo);
+ }
+
+
+ @Override
+ public Result<?> sendSocketMsg(CommandMessageVo msgVo) {
+
+
+ DryEquipment dryEquipment = equipmentService.selectByTenantIdEquipmentId(msgVo.getTenantId() + "", msgVo.getMachineId());
+ log.info("鑾峰彇璁惧锛�" + dryEquipment.toString());
+
+ // managedSessions.keySet().forEach(addr -> {
+ // ObjectOutputStream oos = null;
+ try {
+// Socket socket = SocketServerConfig.clientMap.get(addr);
+ IoSession session = ServerHandler.clientSocket.get(dryEquipment.getIp());
+ if (session == null) {
+ return Result.error("鏈幏鍙栧埌session,璇锋鏌ュ鎴风閰嶇疆鎴栬澶噄p閰嶇疆鏄惁姝ｅ父");
+ }
+ SocketMsgVo smv = new SocketMsgVo(msgVo);
+ session.write(JSONObject.toJSONString(smv));
+// oos = new ObjectOutputStream(socket.getOutputStream());
+// String s = JSONObject.toJSONString(new SocketMsgVo(msgVo));
+// oos.writeUTF(s);
+// oos.flush();
+
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ } finally {
+
+ }
+ // });
+ return Result.OK();
+ }
+
+
+ @Override
+ public Result<?> queryWorkshopStatistics(RealTimeDataVo realTimeDataVo) {
+ LambdaQueryWrapper<DryEquipment> queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(DryEquipment::getTenantId, realTimeDataVo.getTenantid());
+ queryWrapper.eq(DryEquipment::getEnable, "Y");
+ List<DryEquipment> dryEquipments = equipmentService.list(queryWrapper);
+ DryOrderVo orderVo = new DryOrderVo();
+ if (dryEquipments != null && dryEquipments.size() > 0) {
+ dryEquipments.stream().forEach(item -> {
+ DryOrderVo order = (DryOrderVo) redisUtil.hget(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode(), realTimeDataVo.getTenantid() + "_" + item.getCode());
+ if (order != null) {
+ orderVo.setEnvHum(order.getEnvHum());
+ orderVo.setEnvTemp(order.getEnvTemp());
+ double watt = order.getWatt() - order.getDetailList().get(0).getWatt();
+ orderVo.setWatt(orderVo.getWatt()==null? watt : orderVo.getWatt() + watt);
+ double steam = order.getSteam() - order.getDetailList().get(0).getSteam();
+ orderVo.setSteam(orderVo.getSteam()==null? steam : orderVo.getSteam() + steam);
+ orderVo.setOriginWeight(orderVo.getOriginWeight()==null? order.getOriginWeight(): orderVo.getOriginWeight() + order.getOriginWeight());
+
+ double yield = order.getOriginWeight()*(1-(order.getInitial()/100))/(1-(order.getTarget()/100));
+ orderVo.setYield(orderVo.getYield()==null? yield: orderVo.getYield() + yield);
+ double sub = order.getOriginWeight() - order.getYield();
+ orderVo.setReduce(orderVo.getReduce()==null? sub: orderVo.getReduce() + sub);
+
+
+ }
+ });
+ }
+ //redisUtil.get(CacheConstants.RedisKeyEnum.WORK_ORDER.getCode()
+ return Result.OK(orderVo);
+ }
+}
--
Gitblit v1.9.3