Jcdm042-Mes-Module-One.git

2024-07-11 35c489d86b027462dca8bdd06e5fb6dc066fa428

提交 \| 用户 \| 时间
0ca254	1	package com.jcdm.main.om.productionOrde.controller;
A	2
	3	import java.util.ArrayList;
	4	import java.util.Date;
	5	import java.util.List;
35c489	6	import java.util.concurrent.CompletableFuture;
0ca254	7	import javax.servlet.http.HttpServletResponse;
A	8
35c489	9	import cn.hutool.core.util.ObjectUtil;
0ca254	10	import cn.hutool.json.JSONObject;
A	11	import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
	12	import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
	13	import com.jcdm.common.core.domain.entity.SysUser;
	14	import com.jcdm.common.core.domain.model.LoginUser;
	15	import com.jcdm.common.utils.ServletUtils;
	16	import com.jcdm.common.utils.StringUtils;
22c9e0	17	import com.jcdm.framework.websocket.WebSocketUsers;
35c489	18	import com.jcdm.main.constant.Constants;
0ca254	19	import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo;
A	20	import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfoExcelImport;
	21	import com.jcdm.main.om.productionOrde.mapper.OmProductionOrdeInfoMapper;
	22	import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService;
	23	import com.jcdm.main.restful.factoryMes.service.RestfulService;
22c9e0	24	import com.kangaroohy.milo.model.ReadWriteEntity;
A	25	import com.kangaroohy.milo.service.MiloService;
0ca254	26	import lombok.extern.slf4j.Slf4j;
A	27	import org.aspectj.weaver.loadtime.Aj;
	28	import org.slf4j.Logger;
	29	import org.slf4j.LoggerFactory;
	30	import org.springframework.security.access.prepost.PreAuthorize;
	31	import org.springframework.beans.factory.annotation.Autowired;
	32	import org.springframework.web.bind.annotation.GetMapping;
	33	import org.springframework.web.bind.annotation.PostMapping;
	34	import org.springframework.web.bind.annotation.PutMapping;
	35	import org.springframework.web.bind.annotation.DeleteMapping;
	36	import org.springframework.web.bind.annotation.PathVariable;
	37	import org.springframework.web.bind.annotation.RequestBody;
	38	import org.springframework.web.bind.annotation.RequestMapping;
	39	import org.springframework.web.bind.annotation.RestController;
	40	import com.jcdm.common.annotation.Log;
	41	import com.jcdm.common.core.controller.BaseController;
	42	import com.jcdm.common.core.domain.AjaxResult;
	43	import com.jcdm.common.enums.BusinessType;
	44	import com.jcdm.common.utils.poi.ExcelUtil;
	45	import com.jcdm.common.core.page.TableDataInfo;
	46	import org.springframework.web.multipart.MultipartFile;
	47
	48	/**
	49	* 生产工单Controller
	50	*
	51	* @author ruimin
	52	* @date 2023-12-11
	53	*/
	54	@Slf4j
	55	@RestController
	56	@RequestMapping("/om/productionOrde")
	57	public class OmProductionOrdeInfoController extends BaseController
	58	{
	59	private static final Logger logger = LoggerFactory.getLogger("sys-user");
	60
	61	@Autowired
	62	private IOmProductionOrdeInfoService omProductionOrdeInfoService;
22c9e0	63
A	64	@Autowired
	65	private MiloService miloService;
0ca254	66
A	67	/**
	68	* 查询生产工单列表
	69	*/
	70	@PreAuthorize("@ss.hasPermi('om:productionOrde:list')")
	71	@GetMapping("/list")
	72	public TableDataInfo list(OmProductionOrdeInfo omProductionOrdeInfo)
	73	{
	74	startPage();
	75	// List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getWorkOrderNo, "W_202403120001"));
	76	List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.selectOmProductionOrdeInfoList(omProductionOrdeInfo);
	77	return getDataTable(list);
	78	}
	79
	80	@GetMapping("/checkCarCode")
	81	public AjaxResult checkCarCode(OmProductionOrdeInfo omProductionOrdeInfo)
	82	{
	83	Integer i = 0;
	84	List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, omProductionOrdeInfo.getProductNum()));
	85	if(StringUtils.isNotBlank(list.get(0).getTrolleyYard())){
	86	i = 1;
	87	}
	88	return AjaxResult.success(i);
	89	}
	90
	91	@GetMapping("/checkYzSfcCode")
	92	public AjaxResult checkYzSfcCode(OmProductionOrdeInfo omProductionOrdeInfo)
	93	{
	94	Integer i = 0;
	95	List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, omProductionOrdeInfo.getProductNum()));
	96	if(StringUtils.isNotBlank(list.get(0).getSpareField2())){
	97	i = 1;
	98	}
	99	return AjaxResult.success(i);
	100	}
	101
	102	@GetMapping("/bindYzSfcFlag")
	103	public AjaxResult bindYzSfcFlag(OmProductionOrdeInfo omProductionOrdeInfo)
	104	{
	105	List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum, omProductionOrdeInfo.getProductNum()));
	106	list.get(0).setSpareField2("1");
	107	omProductionOrdeInfoService.saveOrUpdate(list.get(0));
	108	return AjaxResult.success(null);
	109	}
	110
	111	/**
	112	* 导出生产工单列表
	113	*/
	114	@PreAuthorize("@ss.hasPermi('om:productionOrde:export')")
	115	@Log(title = "生产工单", businessType = BusinessType.EXPORT)
	116	@PostMapping("/export")
	117	public void export(HttpServletResponse response, OmProductionOrdeInfo omProductionOrdeInfo)
	118	{
	119	List<OmProductionOrdeInfo> list = omProductionOrdeInfoService.selectOmProductionOrdeInfoList(omProductionOrdeInfo);
	120	ExcelUtil<OmProductionOrdeInfo> util = new ExcelUtil<OmProductionOrdeInfo>(OmProductionOrdeInfo.class);
	121	util.exportExcel(response, list, "生产工单数据");
	122	}
	123
	124	@GetMapping("/receivingWorkOrders")
	125	public AjaxResult receivingWorkOrders()
	126	{
	127	String paramProductNum = "";
35c489	128	Object productTypeObjcet = miloService.readFromOpcUa(thoroughfare + "." + device + ".ProductType").getValue();//产品类型
C	129	if (ObjectUtil.isNull(productTypeObjcet)) {
	130	return AjaxResult.error("接单失败,PLC未传输生产类型，请联系管理员");
	131	}
	132	String productType = productTypeObjcet.toString();//产品类型
	133	String materialCode = Constants.materialMap.get(productType);
0ca254	134	// 查询最新的工单信息
22c9e0	135	OmProductionOrdeInfo lastOrder = omProductionOrdeInfoService.getLastOrder();
35c489	136	String orderJsonString = RestfulService.getProductionWorkOrderRequest(lastOrder.getProductNum(), "M1OP100",materialCode);
0ca254	137	JSONObject jsonObject = new JSONObject(orderJsonString);
A	138	// 从JSONObject中获取data对象
	139	JSONObject dataObject = jsonObject.getJSONObject("data");
	140	String code = jsonObject.getStr("code");
	141	// 判断接单是否成功
	142	if(code.equals("success")){
	143	logger.info("请求工厂MES工单：入参pack{}出参pack：{}",paramProductNum,dataObject.getStr("productNum"));
	144	List<OmProductionOrdeInfo> check = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum,dataObject.getStr("productNum")));
	145	if(check.size() == 0){
	146	OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
	147	omProductionOrdeInfo.setWorkOrderNo(dataObject.getStr("productionOrderNum"));
	148	omProductionOrdeInfo.setProductNum(dataObject.getStr("productNum"));
	149	omProductionOrdeInfo.setStationCode(dataObject.getStr("stationCode"));
	150	omProductionOrdeInfo.setMaterialCode(dataObject.getStr("materialCode"));
	151	omProductionOrdeInfo.setOnlineCompletionMark("0");
	152	omProductionOrdeInfo.setSfResult("0");
	153	if(dataObject.getStr("model").equals("PE01A")){
	154	omProductionOrdeInfo.setProductCode("1P102S");
	155	}else {
	156	omProductionOrdeInfo.setProductCode(dataObject.getStr("model"));
	157	}
	158	omProductionOrdeInfo.setCreateTime(new Date());
	159	omProductionOrdeInfo.setCreateUser("工厂MES");
	160	omProductionOrdeInfoService.save(omProductionOrdeInfo);
	161	}
	162	}else {
	163	return AjaxResult.error("接单失败,请联系管理员");
	164	}
	165	return AjaxResult.success(dataObject.getStr("productNum"));
	166	}
	167
22c9e0	168	@GetMapping("/mozuReceivingWorkOrders")
A	169	public AjaxResult mozuReceivingWorkOrders(OmProductionOrdeInfo paramOrder)
	170	{
	171	String paramProductNum = "";
	172	OmProductionOrdeInfo lastOrder = omProductionOrdeInfoService.getLastOrder();
	173	String orderJsonString = RestfulService.getProductionWorkOrderRequest(lastOrder.getProductNum(), "OP230");
	174	JSONObject jsonObject = new JSONObject(orderJsonString);
	175	// 从JSONObject中获取data对象
	176	JSONObject dataObject = jsonObject.getJSONObject("data");
	177	String code = jsonObject.getStr("code");
	178	// 判断接单是否成功
	179	if(code.equals("success")){
	180	logger.info("请求工厂MES工单：入参pack{}出参pack：{}",paramProductNum,dataObject.getStr("productNum"));
	181	List<OmProductionOrdeInfo> check = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum,dataObject.getStr("productNum")));
	182	if(check.size() == 0){
	183	try {
	184	log.info("请求工厂MES工单：入参pack{}出参pack：{}", paramProductNum, dataObject.getStr("productNum"));
	185	OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
	186	omProductionOrdeInfo.setWorkOrderNo(dataObject.getStr("productionOrderNum"));
	187	omProductionOrdeInfo.setProductNum(dataObject.getStr("productNum"));
	188	omProductionOrdeInfo.setStationCode(dataObject.getStr("stationCode"));
	189	omProductionOrdeInfo.setMaterialCode(dataObject.getStr("materialCode"));
	190	omProductionOrdeInfo.setOnlineCompletionMark("0");
	191	omProductionOrdeInfo.setSfResult("0");
	192	omProductionOrdeInfo.setProductCode(dataObject.getStr("model"));
	193	omProductionOrdeInfo.setCreateTime(new Date());
	194	omProductionOrdeInfo.setCreateUser("工厂MES");
	195	omProductionOrdeInfoService.save(omProductionOrdeInfo);
	196	//写PLC
	197	miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("MOZU1." + paramOrder.getLineCode() + ".MES_WorkOrderNumber").value(dataObject.getStr("productionOrderNum")).build());
	198	miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("MOZU1." + paramOrder.getLineCode() + ".MES_ModuleCode").value(dataObject.getStr("productNum")).build());
	199	} catch (Exception e) {
	200	throw new RuntimeException(e);
	201	}
	202	}
	203	}else {
	204	return AjaxResult.error("接单失败,请联系管理员");
	205	}
	206	return AjaxResult.success(dataObject.getStr("productNum"));
	207	}
	208
0ca254	209	@GetMapping(value = "/jieBang/{id}")
A	210	public AjaxResult jieBang(@PathVariable("id") Long id)
	211	{
	212	OmProductionOrdeInfo byId = omProductionOrdeInfoService.getById(id);
	213	byId.setTrolleyYard("");
	214	return success(omProductionOrdeInfoService.saveOrUpdate(byId));
	215	}
	216
	217	/**
	218	* 获取生产工单详细信息
	219	*/
	220	@PreAuthorize("@ss.hasPermi('om:productionOrde:query')")
	221	@GetMapping(value = "/{id}")
	222	public AjaxResult getInfo(@PathVariable("id") Long id)
	223	{
	224	return success(omProductionOrdeInfoService.selectOmProductionOrdeInfoById(id));
	225	}
	226
	227	/**
	228	* 新增生产工单
	229	*/
	230	@PreAuthorize("@ss.hasPermi('om:productionOrde:add')")
	231	@Log(title = "生产工单", businessType = BusinessType.INSERT)
	232	@PostMapping
	233	public AjaxResult add(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	234	{
	235	return toAjax(omProductionOrdeInfoService.insertOmProductionOrdeInfo(omProductionOrdeInfo));
	236	}
	237
	238	/**
	239	* 修改生产工单
	240	*/
	241	@PreAuthorize("@ss.hasPermi('om:productionOrde:edit')")
	242	@Log(title = "生产工单", businessType = BusinessType.UPDATE)
	243	@PutMapping
	244	public AjaxResult edit(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	245	{
	246	return toAjax(omProductionOrdeInfoService.updateOmProductionOrdeInfo(omProductionOrdeInfo));
	247	}
	248
	249	/**
	250	* 删除生产工单
	251	*/
	252	@PreAuthorize("@ss.hasPermi('om:productionOrde:remove')")
	253	@Log(title = "生产工单", businessType = BusinessType.DELETE)
	254	@DeleteMapping("/{ids}")
	255	public AjaxResult remove(@PathVariable Long[] ids)
	256	{
	257	return toAjax(omProductionOrdeInfoService.deleteOmProductionOrdeInfoByIds(ids));
	258	}
	259
	260	/**
	261	* table列上移下移
	262	*/
	263	@Log(title = "生产工单", businessType = BusinessType.DELETE)
	264	@GetMapping("/upDownMove")
	265	public AjaxResult upDownMove(OmProductionOrdeInfo omProductionOrdeInfo)
	266	{
	267	return omProductionOrdeInfoService.upDownMove(omProductionOrdeInfo);
	268	}
	269
	270	@PostMapping("/importData")
	271	public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception
	272	{
	273	ExcelUtil<OmProductionOrdeInfo> util = new ExcelUtil<OmProductionOrdeInfo>(OmProductionOrdeInfo.class);
	274	List<OmProductionOrdeInfo> ordeInfo = util.importExcel(file.getInputStream());
	275	for (OmProductionOrdeInfo omProductionOrdeInfo : ordeInfo) {
	276	omProductionOrdeInfo.setCreateTime(new Date());
	277	omProductionOrdeInfo.setCreateBy("工厂MES");
	278	}
	279	omProductionOrdeInfoService.overrideSaveBatch(ordeInfo);
	280	return AjaxResult.success();
	281	}
	282
	283	@PostMapping("/importTemplate")
	284	public void importTemplate(HttpServletResponse response)
	285	{
	286	ExcelUtil<OmProductionOrdeInfoExcelImport> util = new ExcelUtil<OmProductionOrdeInfoExcelImport>(OmProductionOrdeInfoExcelImport.class);
	287	util.importTemplateExcel(response, "订单数据");
	288	}
	289
	290	@PostMapping("/trolleyYardBinDing")
	291	public AjaxResult trolleyYardBinDing(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	292	{
	293	return omProductionOrdeInfoService.trolleyYardBinDing(omProductionOrdeInfo);
	294	}
	295
	296	@PostMapping("/getCarCodeSize")
	297	public AjaxResult getCarCodeSize(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	298	{
	299	return omProductionOrdeInfoService.getCarCodeSize(omProductionOrdeInfo);
	300	}
	301
	302	@PostMapping("/findBytrolleyYardGetOne")
	303	public AjaxResult findBytrolleyYardGetOne(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	304	{
	305	return omProductionOrdeInfoService.findBytrolleyYardGetOne(omProductionOrdeInfo);
	306	}
	307
	308	@GetMapping("/workReportingByStation/{id}/{stationCode}")
	309	public AjaxResult workReportingByStation(@PathVariable("id") Long id, @PathVariable("stationCode") String stationCode)
	310	{
	311	OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
	312	omProductionOrdeInfo.setId(id);
	313	omProductionOrdeInfo.setStationCode(stationCode);
	314	return omProductionOrdeInfoService.workReportingByStation(omProductionOrdeInfo);
	315	}
	316	}