Jcdm041-MesCVT.git

hdy

2024-07-13 d9502f15ba2829816b466385df558ce266a8e197

提交 \| 用户 \| 时间
0cceb6	1	package com.jcdm.main.da.passingStationCollection.controller;
Y	2
8069b5	3	import java.util.Date;
0cceb6	4	import java.util.List;
Y	5	import javax.servlet.http.HttpServletResponse;
	6
	7	import com.jcdm.common.core.domain.R;
	8	import com.jcdm.common.utils.DateUtils;
	9	import com.jcdm.main.bs.orderScheduling.domain.BsOrderScheduling;
8069b5	10	import com.jcdm.main.da.paramCollection.domain.DaParamCollection;
0cceb6	11	import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection;
Y	12	import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService;
	13	import com.jcdm.main.da.passingStationCollection.vo.DaPassingStationVO;
8069b5	14	import com.kangaroohy.milo.model.ReadWriteEntity;
0cceb6	15	import org.springframework.security.access.prepost.PreAuthorize;
Y	16	import org.springframework.beans.factory.annotation.Autowired;
8069b5	17	import org.springframework.web.bind.annotation.*;
0cceb6	18	import com.jcdm.common.annotation.Log;
Y	19	import com.jcdm.common.core.controller.BaseController;
	20	import com.jcdm.common.core.domain.AjaxResult;
	21	import com.jcdm.common.enums.BusinessType;
	22	import com.jcdm.common.utils.poi.ExcelUtil;
	23	import com.jcdm.common.core.page.TableDataInfo;
8069b5	24
H	25	import static com.jcdm.main.plcserver.callback.InitCallback.miloService;
0cceb6	26
Y	27	/**
	28	* 产品过站采集Controller
	29	*
	30	* @author yyt
	31	* @date 2023-12-12
	32	*/
	33	@RestController
	34	@RequestMapping("/da/passingStationCollection")
8069b5	35	public class DaPassingStationCollectionController extends BaseController {
0cceb6	36	@Autowired
Y	37	private IDaPassingStationCollectionService daPassingStationCollectionService;
	38
	39	/**
	40	* 查询产品过站采集列表
	41	*/
	42	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:list')")
	43	@GetMapping("/list")
8069b5	44	public TableDataInfo list(DaPassingStationCollection daPassingStationCollection) {
0cceb6	45	startPage();
Y	46	List<DaPassingStationCollection> list = daPassingStationCollectionService.selectDaPassingStationCollectionList(daPassingStationCollection);
	47	return getDataTable(list);
	48	}
	49
	50	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:list')")
	51	@GetMapping("/getTopProcess")
8069b5	52	public TableDataInfo getTopProcess() {
0cceb6	53	DaPassingStationCollection daPassingStationCollection = new DaPassingStationCollection();
Y	54	List<DaPassingStationVO> list = daPassingStationCollectionService.getTopProcess(daPassingStationCollection);
	55	return getDataTable(list);
	56	}
8069b5	57
0cceb6	58	/**
Y	59	* 查询产品过站采集列表
	60	*/
	61	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:list')")
	62	@GetMapping("/noPageList")
8069b5	63	public TableDataInfo noPageList(DaPassingStationCollection daPassingStationCollection) {
0cceb6	64	List<DaPassingStationCollection> list = daPassingStationCollectionService.selectDaPassingStationCollectionList(daPassingStationCollection);
Y	65	return getDataTable(list);
	66	}
	67
	68	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:list')")
	69	@GetMapping("/getProduceNumToday")
8069b5	70	public R getProduceNumToday(String fieldName) {
0cceb6	71	Integer num = daPassingStationCollectionService.getProduceNumToday(fieldName);
Y	72	return R.ok(num);
	73	}
	74
	75	/**
	76	* 查询产品过站采集列表
	77	*/
	78	@GetMapping("/insertRepairRecordByIds")
8069b5	79	public AjaxResult insertRepairRecordByIds(DaPassingStationCollection daPassingStationCollection) {
0cceb6	80	daPassingStationCollectionService.insertRepairRecordByIds(daPassingStationCollection);
Y	81	return AjaxResult.success();
	82	}
	83
	84	/**
	85	* 导出产品过站采集列表
	86	*/
	87	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:export')")
	88	@Log(title = "产品过站采集", businessType = BusinessType.EXPORT)
	89	@PostMapping("/export")
8069b5	90	public void export(HttpServletResponse response, DaPassingStationCollection daPassingStationCollection) {
0cceb6	91	List<DaPassingStationCollection> list = daPassingStationCollectionService.selectDaPassingStationCollectionList(daPassingStationCollection);
Y	92	ExcelUtil<DaPassingStationCollection> util = new ExcelUtil<DaPassingStationCollection>(DaPassingStationCollection.class);
	93	util.exportExcel(response, list, "产品过站采集数据");
	94	}
	95
	96	/**
	97	* 获取产品过站采集详细信息
	98	*/
	99	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:query')")
	100	@GetMapping(value = "/{id}")
8069b5	101	public AjaxResult getInfo(@PathVariable("id") Long id) {
0cceb6	102	return success(daPassingStationCollectionService.selectDaPassingStationCollectionById(id));
Y	103	}
	104
	105	/**
	106	* 新增产品过站采集
	107	*/
	108	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:add')")
	109	@Log(title = "产品过站采集", businessType = BusinessType.INSERT)
	110	@PostMapping
8069b5	111	public AjaxResult add(@RequestBody DaPassingStationCollection daPassingStationCollection) {
0cceb6	112	daPassingStationCollection.setCreateBy(getUsername());
Y	113	daPassingStationCollection.setCreateTime(DateUtils.getNowDate());
	114	return toAjax(daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection));
	115	}
	116
	117	/**
	118	* 修改产品过站采集
	119	*/
	120	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:edit')")
	121	@Log(title = "产品过站采集", businessType = BusinessType.UPDATE)
	122	@PutMapping
8069b5	123	public AjaxResult edit(@RequestBody DaPassingStationCollection daPassingStationCollection) {
0cceb6	124	daPassingStationCollection.setUpdateBy(getUsername());
Y	125	daPassingStationCollection.setUpdateTime(DateUtils.getNowDate());
	126	return toAjax(daPassingStationCollectionService.updateDaPassingStationCollection(daPassingStationCollection));
	127	}
	128
	129	/**
	130	* 删除产品过站采集
	131	*/
	132	@PreAuthorize("@ss.hasPermi('da:passingStationCollection:remove')")
	133	@Log(title = "产品过站采集", businessType = BusinessType.DELETE)
8069b5	134	@DeleteMapping("/{ids}")
H	135	public AjaxResult remove(@PathVariable Long[] ids) {
0cceb6	136	return toAjax(daPassingStationCollectionService.deleteDaPassingStationCollectionByIds(ids));
Y	137	}
8069b5	138
H	139
	140	// @PreAuthorize("@ss.hasPermi('da:passingStationCollection:query')")
	141	// @Log(title = "产品过站采集", businessType = BusinessType.INSERT)
	142	// @GetMapping(value = "/addPassing")
	143	// public R addPassing(String sfcCode,String locationCode) {
	144	//
	145	// DaPassingStationCollection saveData = new DaPassingStationCollection();
	146	// saveData.setSfcCode(sfcCode);
	147	// saveData.setLocationCode(locationCode);
	148	// saveData.setCollectionTime(new Date());
	149	// daPassingStationCollectionService.insertDaPassingStationCollection(saveData);
	150	//
	151	// return R.ok();
	152	//
	153	// }
	154
	155
	156	@GetMapping("/initializedData")
	157	public AjaxResult initializedData(@RequestParam String sfcCode, @RequestParam String locationCode) {
	158
	159	try {
a4362d	160	String str = "CFL4CVT."+locationCode+".RecordData";
H	161	Object recordDataObject = miloService.readFromOpcUa(str).getValue();
	162	if(Integer.valueOf(recordDataObject.toString())== 1){
	163	miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("CFL4CVT." + locationCode + ".MesSNCode").value(sfcCode).build());
	164	ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT." + locationCode + ".MesRecordDataDone", 11);
	165	miloService.writeToOpcShort(entity);
	166	return AjaxResult.success("扫码成功");
	167	}else {
	168	return AjaxResult.error(500,"未进站禁止扫码");
	169	}
	170	// ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT." + locationCode + ".MesSNCode", sfcCode);
	171	// miloService.writeToOpcChar(entity);
	172	// String nodeId = "CFL4CVT." + locationCode + ".MesSNCode";
	173	// String SaveSNCode ="CFL4CVT." + locationCode + ".SaveSNCode";
	174	// ReadWriteEntity SaveSNCodeEntity = new ReadWriteEntity(SaveSNCode, 11);
	175	// miloService.writeToOpcShort(SaveSNCodeEntity);
	176	// return AjaxResult.success("SFC Code updated successfully");
8069b5	177	} catch (Exception e) {
d9502f	178	throw new RuntimeException("扫码错误", e);
8069b5	179	}
H	180	}
	181
	182	}