HangZhouMes.git

			@@ -4,12 +4,13 @@
			import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.github.yulichang.query.MPJQueryWrapper;
			import com.mes.common.S7object;
			import com.mes.common.utils.RedisUtil;
			import com.mes.damage.entity.Damage;
			import com.mes.damage.service.DamageService;
			import com.mes.device.PlcParameterObject;
			import com.mes.downglassinfo.entity.DownGlassInfo;
			import com.mes.downglassinfo.mapper.DownGlassInfoMapper;
			import com.mes.downglassinfo.service.DownGlassInfoService;
			import com.mes.downglassinfo.service.DownGlassTaskService;
			import com.mes.downworkstation.entity.DownWorkstation;
			import com.mes.downworkstation.entity.DownWorkstationTask;
			import com.mes.downworkstation.entity.DownWorkstionAndDownGlassinfo;
			@@ -23,6 +24,7 @@
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;

			import javax.annotation.Resource;
			import java.util.ArrayList;
			import java.util.HashMap;
			import java.util.List;
			@@ -37,11 +39,7 @@
			@Autowired(required = false)
			private DownWorkstationTaskMapper downWorkstationTaskMapper;
			@Autowired
			private DownGlassInfoService downGlassInfoService;
			@Autowired
			private DownGlassInfoMapper downGlassInfoMapper;
			@Autowired
			private DownGlassTaskService downGlassTaskService;
			@Autowired
			private GlassInfoService glassInfoService;
			@Autowired
			@@ -49,6 +47,8 @@

			@Autowired
			private DownWorkstationTaskService downWorkstationTaskService;
			@Resource
			private RedisUtil redisUtil;

			// @Override
			// public List<DownWorkstation> gettwoDownWorkstations() {
			@@ -69,7 +69,7 @@
			@Override
			public List<Map<String, Object>> getTotalGlassDimensionsByWorkstation(int start, int end) {
			MPJQueryWrapper<DownWorkstation> queryWrapper = new MPJQueryWrapper<>();
			queryWrapper.select("t.workstation_id", "t.flow_card_id", "COALESCE(SUM(b.width), 0) AS totalwidth", "COALESCE(SUM(b.height), 0) AS totalheight")
			queryWrapper.select("t.workstation_id", "t.flow_card_id", "COALESCE(SUM(b.width), 0) AS totalwidth", "COALESCE(SUM(b.height), 0) AS totalheight,total_quantity,racks_number,other_number")
			.leftJoin("down_glass_info b on t.flow_card_id = b.flow_card_id")
			.groupBy("t.workstation_id", "t.flow_card_id")
			.orderByAsc("t.workstation_id").between("t.workstation_id", start, end)
			@@ -86,6 +86,11 @@
			item.put("width", downWorkstionAndDownGlassinfo.getTotalwidth());
			item.put("fillColor", "yellow");
			item.put("content", downWorkstionAndDownGlassinfo.getFlowCardId());
			if (downWorkstionAndDownGlassinfo.getFlowCardId() != "" && downWorkstionAndDownGlassinfo.getFlowCardId() != null && downWorkstionAndDownGlassinfo.getTotalQuantity() == downWorkstionAndDownGlassinfo.getRacksNumber() + downWorkstionAndDownGlassinfo.getRacksNumber()) {
			item.put("fullCardColor", "red");
			} else {
			item.put("fullCardColor", "blue");
			}

			// 查询 DownGlassInfo 并添加到 item 中
			MPJQueryWrapper<DownGlassInfo> glassInfoQueryWrapper = new MPJQueryWrapper<>();
			@@ -141,12 +146,11 @@


			@Override
			public int updateFlowCardIdAndCount(String flowCardId, int workstationId, int layer) {
			public void updateFlowCardIdAndCount(String flowCardId, int workstationId, int layer) {
			int glassInfoCount = glassInfoService.getGlassInfoCountByFlowCardId(flowCardId, layer);
			QueryWrapper<Damage> queryWrapper = new QueryWrapper<>();
			queryWrapper.eq("process_id", flowCardId);
			queryWrapper.eq("technology_number", layer);

			int otherNumber = damageservice.count(queryWrapper);
			UpdateWrapper<DownWorkstation> updateWrapper = new UpdateWrapper<>();
			updateWrapper.set("total_quantity", glassInfoCount)
			@@ -154,8 +158,9 @@
			.set("layer", layer)
			.set("other_number", otherNumber)
			.eq("workstation_id", workstationId);
			// .eq("id", workstationId);
			this.update(updateWrapper);
			return 1;

			}

			@Override
			@@ -164,6 +169,8 @@
			updateWrapper.set("flow_card_id", null)
			.set("total_quantity", 0)
			.set("racks_number", 0)
			.set("other_number", 0)
			.set("layer", null)
			.eq("workstation_id", workstationId);

			baseMapper.update(new DownWorkstation(), updateWrapper);
			@@ -190,4 +197,48 @@
			}


			@Override
			public boolean updateDownWorkstationstate(DownWorkstation downWorkstation) {

			DownWorkstation downWork = baseMapper.selectById(downWorkstation.getId());

			if (downWork != null) {

			downWork.setEnableState(downWorkstation.getEnableState());

			baseMapper.updateById(downWork);

			return true;
			} else {

			return false;
			}
			}

			@Override
			public String closeAlarmSignal() {
			PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
			S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("alarm_signal").getAddress(), 0);
			return "success";
			}

			@Override
			public void autoPrint(Boolean flag) {
			redisUtil.setCacheObject("autoPrint", flag);
			}

			@Override
			public void insertDownWorkstation() {
			DownWorkstation downWorkstation = new DownWorkstation();
			downWorkstation.setWorkstationId(7);
			downWorkstation.setTotalQuantity(0);
			downWorkstation.setRacksNumber(0);
			downWorkstation.setOtherNumber(0);
			downWorkstation.setDeviceId(3);
			downWorkstation.setEnableState(1);
			downWorkstation.setWorkState(1);
			baseMapper.insert(downWorkstation);
			}


			}