Jcdm042-Mes-Module-One.git

2024-07-12 ab63141eaf175c6c544d2ef37833dea9016d0d26

提交 \| 用户 \| 时间
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
22c9e0	124	@GetMapping("/mozuReceivingWorkOrders")
1ebf2a	125	public AjaxResult mozuReceivingWorkOrders(OmProductionOrdeInfo paramOrder) throws Exception {
22c9e0	126	String paramProductNum = "";
09ceef	127	Object productTypeObjcet = miloService.readFromOpcUa("MOZU1." + paramOrder.getLineCode() + ".ProductType").getValue();//产品类型
1ebf2a	128	if (ObjectUtil.isNull(productTypeObjcet)) {
C	129	return AjaxResult.error("接单失败,PLC未传输生产类型，请联系管理员");
	130	}
	131	String productType = productTypeObjcet.toString();//产品类型
	132	String materialCode = Constants.materialMap.get(productType);
	133
22c9e0	134	OmProductionOrdeInfo lastOrder = omProductionOrdeInfoService.getLastOrder();
1ebf2a	135	String orderJsonString = RestfulService.getProductionWorkOrderRequest(lastOrder.getProductNum(), "M1OP100",materialCode);
22c9e0	136	JSONObject jsonObject = new JSONObject(orderJsonString);
A	137	// 从JSONObject中获取data对象
	138	JSONObject dataObject = jsonObject.getJSONObject("data");
	139	String code = jsonObject.getStr("code");
	140	// 判断接单是否成功
	141	if(code.equals("success")){
	142	logger.info("请求工厂MES工单：入参pack{}出参pack：{}",paramProductNum,dataObject.getStr("productNum"));
	143	List<OmProductionOrdeInfo> check = omProductionOrdeInfoService.list(new LambdaQueryWrapper<OmProductionOrdeInfo>().eq(OmProductionOrdeInfo::getProductNum,dataObject.getStr("productNum")));
ab6314	144	if(check.isEmpty()){
22c9e0	145	try {
A	146	log.info("请求工厂MES工单：入参pack{}出参pack：{}", paramProductNum, dataObject.getStr("productNum"));
	147	OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
	148	omProductionOrdeInfo.setWorkOrderNo(dataObject.getStr("productionOrderNum"));
	149	omProductionOrdeInfo.setProductNum(dataObject.getStr("productNum"));
	150	omProductionOrdeInfo.setStationCode(dataObject.getStr("stationCode"));
	151	omProductionOrdeInfo.setMaterialCode(dataObject.getStr("materialCode"));
653b17	152	omProductionOrdeInfo.setPlanQty(Long.valueOf(dataObject.getStr("plannedQuantity")));
22c9e0	153	omProductionOrdeInfo.setOnlineCompletionMark("0");
A	154	omProductionOrdeInfo.setSfResult("0");
	155	omProductionOrdeInfo.setProductCode(dataObject.getStr("model"));
	156	omProductionOrdeInfo.setCreateTime(new Date());
	157	omProductionOrdeInfo.setCreateUser("工厂MES");
	158	omProductionOrdeInfoService.save(omProductionOrdeInfo);
ab6314	159
22c9e0	160	//写PLC
ab6314	161	miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("MOZU1." + paramOrder.getLineCode() + ".WorkOrderNumber").value(dataObject.getStr("productionOrderNum")).build());
C	162	miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("MOZU1." + paramOrder.getLineCode() + ".ModuleCode").value(dataObject.getStr("productNum")).build());
22c9e0	163	} catch (Exception e) {
A	164	throw new RuntimeException(e);
	165	}
ab6314	166	}else{
C	167	return AjaxResult.error("工单重复,请重新接收");
22c9e0	168	}
A	169	}else {
	170	return AjaxResult.error("接单失败,请联系管理员");
	171	}
	172	return AjaxResult.success(dataObject.getStr("productNum"));
	173	}
	174
0ca254	175	@GetMapping(value = "/jieBang/{id}")
A	176	public AjaxResult jieBang(@PathVariable("id") Long id)
	177	{
	178	OmProductionOrdeInfo byId = omProductionOrdeInfoService.getById(id);
	179	byId.setTrolleyYard("");
	180	return success(omProductionOrdeInfoService.saveOrUpdate(byId));
	181	}
	182
	183	/**
	184	* 获取生产工单详细信息
	185	*/
	186	@PreAuthorize("@ss.hasPermi('om:productionOrde:query')")
	187	@GetMapping(value = "/{id}")
	188	public AjaxResult getInfo(@PathVariable("id") Long id)
	189	{
	190	return success(omProductionOrdeInfoService.selectOmProductionOrdeInfoById(id));
	191	}
	192
	193	/**
	194	* 新增生产工单
	195	*/
	196	@PreAuthorize("@ss.hasPermi('om:productionOrde:add')")
	197	@Log(title = "生产工单", businessType = BusinessType.INSERT)
	198	@PostMapping
	199	public AjaxResult add(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	200	{
	201	return toAjax(omProductionOrdeInfoService.insertOmProductionOrdeInfo(omProductionOrdeInfo));
	202	}
	203
	204	/**
	205	* 修改生产工单
	206	*/
	207	@PreAuthorize("@ss.hasPermi('om:productionOrde:edit')")
	208	@Log(title = "生产工单", businessType = BusinessType.UPDATE)
	209	@PutMapping
	210	public AjaxResult edit(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	211	{
	212	return toAjax(omProductionOrdeInfoService.updateOmProductionOrdeInfo(omProductionOrdeInfo));
	213	}
	214
	215	/**
	216	* 删除生产工单
	217	*/
	218	@PreAuthorize("@ss.hasPermi('om:productionOrde:remove')")
	219	@Log(title = "生产工单", businessType = BusinessType.DELETE)
	220	@DeleteMapping("/{ids}")
	221	public AjaxResult remove(@PathVariable Long[] ids)
	222	{
	223	return toAjax(omProductionOrdeInfoService.deleteOmProductionOrdeInfoByIds(ids));
	224	}
	225
	226	/**
	227	* table列上移下移
	228	*/
	229	@Log(title = "生产工单", businessType = BusinessType.DELETE)
	230	@GetMapping("/upDownMove")
	231	public AjaxResult upDownMove(OmProductionOrdeInfo omProductionOrdeInfo)
	232	{
	233	return omProductionOrdeInfoService.upDownMove(omProductionOrdeInfo);
	234	}
	235
	236	@PostMapping("/importData")
	237	public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception
	238	{
	239	ExcelUtil<OmProductionOrdeInfo> util = new ExcelUtil<OmProductionOrdeInfo>(OmProductionOrdeInfo.class);
	240	List<OmProductionOrdeInfo> ordeInfo = util.importExcel(file.getInputStream());
	241	for (OmProductionOrdeInfo omProductionOrdeInfo : ordeInfo) {
	242	omProductionOrdeInfo.setCreateTime(new Date());
	243	omProductionOrdeInfo.setCreateBy("工厂MES");
	244	}
	245	omProductionOrdeInfoService.overrideSaveBatch(ordeInfo);
	246	return AjaxResult.success();
	247	}
	248
	249	@PostMapping("/importTemplate")
	250	public void importTemplate(HttpServletResponse response)
	251	{
	252	ExcelUtil<OmProductionOrdeInfoExcelImport> util = new ExcelUtil<OmProductionOrdeInfoExcelImport>(OmProductionOrdeInfoExcelImport.class);
	253	util.importTemplateExcel(response, "订单数据");
	254	}
	255
	256	@PostMapping("/trolleyYardBinDing")
	257	public AjaxResult trolleyYardBinDing(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	258	{
	259	return omProductionOrdeInfoService.trolleyYardBinDing(omProductionOrdeInfo);
	260	}
	261
	262	@PostMapping("/getCarCodeSize")
	263	public AjaxResult getCarCodeSize(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	264	{
	265	return omProductionOrdeInfoService.getCarCodeSize(omProductionOrdeInfo);
	266	}
	267
	268	@PostMapping("/findBytrolleyYardGetOne")
	269	public AjaxResult findBytrolleyYardGetOne(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	270	{
	271	return omProductionOrdeInfoService.findBytrolleyYardGetOne(omProductionOrdeInfo);
	272	}
	273
	274	@GetMapping("/workReportingByStation/{id}/{stationCode}")
	275	public AjaxResult workReportingByStation(@PathVariable("id") Long id, @PathVariable("stationCode") String stationCode)
	276	{
	277	OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
	278	omProductionOrdeInfo.setId(id);
	279	omProductionOrdeInfo.setStationCode(stationCode);
	280	return omProductionOrdeInfoService.workReportingByStation(omProductionOrdeInfo);
	281	}
	282	}