Jcdm042-Mes-Module-One.git

admin

2024-07-11 653b17eac39c339774cd46291a9345493b253a1f

提交 \| 用户 \| 时间
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")));
	144	if(check.size() == 0){
	145	try {
	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);
	159	//写PLC
	160	miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("MOZU1." + paramOrder.getLineCode() + ".MES_WorkOrderNumber").value(dataObject.getStr("productionOrderNum")).build());
	161	miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("MOZU1." + paramOrder.getLineCode() + ".MES_ModuleCode").value(dataObject.getStr("productNum")).build());
	162	} catch (Exception e) {
	163	throw new RuntimeException(e);
	164	}
	165	}
	166	}else {
	167	return AjaxResult.error("接单失败,请联系管理员");
	168	}
	169	return AjaxResult.success(dataObject.getStr("productNum"));
	170	}
	171
0ca254	172	@GetMapping(value = "/jieBang/{id}")
A	173	public AjaxResult jieBang(@PathVariable("id") Long id)
	174	{
	175	OmProductionOrdeInfo byId = omProductionOrdeInfoService.getById(id);
	176	byId.setTrolleyYard("");
	177	return success(omProductionOrdeInfoService.saveOrUpdate(byId));
	178	}
	179
	180	/**
	181	* 获取生产工单详细信息
	182	*/
	183	@PreAuthorize("@ss.hasPermi('om:productionOrde:query')")
	184	@GetMapping(value = "/{id}")
	185	public AjaxResult getInfo(@PathVariable("id") Long id)
	186	{
	187	return success(omProductionOrdeInfoService.selectOmProductionOrdeInfoById(id));
	188	}
	189
	190	/**
	191	* 新增生产工单
	192	*/
	193	@PreAuthorize("@ss.hasPermi('om:productionOrde:add')")
	194	@Log(title = "生产工单", businessType = BusinessType.INSERT)
	195	@PostMapping
	196	public AjaxResult add(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	197	{
	198	return toAjax(omProductionOrdeInfoService.insertOmProductionOrdeInfo(omProductionOrdeInfo));
	199	}
	200
	201	/**
	202	* 修改生产工单
	203	*/
	204	@PreAuthorize("@ss.hasPermi('om:productionOrde:edit')")
	205	@Log(title = "生产工单", businessType = BusinessType.UPDATE)
	206	@PutMapping
	207	public AjaxResult edit(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	208	{
	209	return toAjax(omProductionOrdeInfoService.updateOmProductionOrdeInfo(omProductionOrdeInfo));
	210	}
	211
	212	/**
	213	* 删除生产工单
	214	*/
	215	@PreAuthorize("@ss.hasPermi('om:productionOrde:remove')")
	216	@Log(title = "生产工单", businessType = BusinessType.DELETE)
	217	@DeleteMapping("/{ids}")
	218	public AjaxResult remove(@PathVariable Long[] ids)
	219	{
	220	return toAjax(omProductionOrdeInfoService.deleteOmProductionOrdeInfoByIds(ids));
	221	}
	222
	223	/**
	224	* table列上移下移
	225	*/
	226	@Log(title = "生产工单", businessType = BusinessType.DELETE)
	227	@GetMapping("/upDownMove")
	228	public AjaxResult upDownMove(OmProductionOrdeInfo omProductionOrdeInfo)
	229	{
	230	return omProductionOrdeInfoService.upDownMove(omProductionOrdeInfo);
	231	}
	232
	233	@PostMapping("/importData")
	234	public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception
	235	{
	236	ExcelUtil<OmProductionOrdeInfo> util = new ExcelUtil<OmProductionOrdeInfo>(OmProductionOrdeInfo.class);
	237	List<OmProductionOrdeInfo> ordeInfo = util.importExcel(file.getInputStream());
	238	for (OmProductionOrdeInfo omProductionOrdeInfo : ordeInfo) {
	239	omProductionOrdeInfo.setCreateTime(new Date());
	240	omProductionOrdeInfo.setCreateBy("工厂MES");
	241	}
	242	omProductionOrdeInfoService.overrideSaveBatch(ordeInfo);
	243	return AjaxResult.success();
	244	}
	245
	246	@PostMapping("/importTemplate")
	247	public void importTemplate(HttpServletResponse response)
	248	{
	249	ExcelUtil<OmProductionOrdeInfoExcelImport> util = new ExcelUtil<OmProductionOrdeInfoExcelImport>(OmProductionOrdeInfoExcelImport.class);
	250	util.importTemplateExcel(response, "订单数据");
	251	}
	252
	253	@PostMapping("/trolleyYardBinDing")
	254	public AjaxResult trolleyYardBinDing(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	255	{
	256	return omProductionOrdeInfoService.trolleyYardBinDing(omProductionOrdeInfo);
	257	}
	258
	259	@PostMapping("/getCarCodeSize")
	260	public AjaxResult getCarCodeSize(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	261	{
	262	return omProductionOrdeInfoService.getCarCodeSize(omProductionOrdeInfo);
	263	}
	264
	265	@PostMapping("/findBytrolleyYardGetOne")
	266	public AjaxResult findBytrolleyYardGetOne(@RequestBody OmProductionOrdeInfo omProductionOrdeInfo)
	267	{
	268	return omProductionOrdeInfoService.findBytrolleyYardGetOne(omProductionOrdeInfo);
	269	}
	270
	271	@GetMapping("/workReportingByStation/{id}/{stationCode}")
	272	public AjaxResult workReportingByStation(@PathVariable("id") Long id, @PathVariable("stationCode") String stationCode)
	273	{
	274	OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
	275	omProductionOrdeInfo.setId(id);
	276	omProductionOrdeInfo.setStationCode(stationCode);
	277	return omProductionOrdeInfoService.workReportingByStation(omProductionOrdeInfo);
	278	}
	279	}