From 220b7c57963afb0b3190f00f0ae72ace767162bf Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期四, 04 三月 2021 14:31:37 +0800 Subject: [PATCH] # --- src/main/java/zy/cloud/wms/common/service/erp/ErpScheduler.java | 71 ++++++++++++++++++++++++++++++++++- src/main/resources/mapper/MatMapper.xml | 2 2 files changed, 70 insertions(+), 3 deletions(-) diff --git a/src/main/java/zy/cloud/wms/common/service/erp/ErpScheduler.java b/src/main/java/zy/cloud/wms/common/service/erp/ErpScheduler.java index 81446c3..1672dde 100644 --- a/src/main/java/zy/cloud/wms/common/service/erp/ErpScheduler.java +++ b/src/main/java/zy/cloud/wms/common/service/erp/ErpScheduler.java @@ -1,6 +1,7 @@ package zy.cloud.wms.common.service.erp; import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.core.common.DateUtils; import lombok.extern.slf4j.Slf4j; @@ -9,8 +10,10 @@ import org.springframework.transaction.annotation.Transactional; import zy.cloud.wms.common.service.erp.entity.GetBasisResult; import zy.cloud.wms.common.service.erp.entity.GetOrderResult; +import zy.cloud.wms.manager.entity.Cstmr; import zy.cloud.wms.manager.entity.CustOrder; import zy.cloud.wms.manager.entity.Mat; +import zy.cloud.wms.manager.service.CstmrService; import zy.cloud.wms.manager.service.CustOrderService; import zy.cloud.wms.manager.service.MatService; import zy.cloud.wms.manager.utils.HttpHandler; @@ -39,13 +42,15 @@ private CustOrderService custOrderService; @Autowired private MatService matService; + @Autowired + private CstmrService cstmrService; /** - * 鍟嗗搧/瀹㈡埛涓嬭浇 + * 鍟嗗搧涓嬭浇 */ // @Scheduled(cron = "0/5 * * * * ? ") @PostConstruct - public void getBasisExecute(){ + public void getBasis1Execute(){ try { Map<String, Object> param = new HashMap<>(); param.put("rec", 0); @@ -115,6 +120,68 @@ } /** + * 瀹㈡埛涓嬭浇 + */ + // @Scheduled(cron = "0/5 * * * * ? ") + @PostConstruct + public void getBasis2Execute(){ + try { + Map<String, Object> param = new HashMap<>(); + param.put("rec", 0); + param.put("Flag", 2); + String response = new HttpHandler.Builder() + .setUri(URI) + .setPath(GET_BASIS) + .setJson(JSON.toJSONString(param)) + .build() + .doPost(); + if (!Cools.isEmpty(response)) { + log.info(response); + Date now = new Date(); + Result result = JSON.parseObject(response, Result.class); + if (result.getCode() != 1) { + return; + } + List<GetBasisResult> list = JSON.parseArray(result.getData(), GetBasisResult.class); + for (GetBasisResult data : list) { + Cstmr cstmr = cstmrService.selectOne(new EntityWrapper<Cstmr>().eq("uuid", data.getUserCode())); + String modifyDate = data.getModifyDate(); + Date updateTime = null; + if (!Cools.isEmpty(modifyDate)) { + updateTime = DateUtils.convert(data.getModifyDate()); + } + if (null == cstmr) { + cstmr = new Cstmr( + data.getUserCode(), // 瀹㈡埛缂栧彿[闈炵┖] + data.getFullName(), // 瀹㈡埛鍚嶇О + null, // 鑱旂郴浜� + null, // 鑱旂郴鐢佃瘽 + null, // 鑱旂郴鍦板潃 + 1, // 鐘舵�� + null, // 娣诲姞浜哄憳 + now, // 娣诲姞鏃堕棿 + null, // 淇敼浜哄憳 + updateTime, // 淇敼鏃堕棿 + String.valueOf(data.getRec()) // 澶囨敞 + ); + cstmrService.insert(cstmr); + } else { + cstmr.setUuid(data.getUserCode()); + cstmr.setName(data.getFullName()); + cstmr.setUpdateTime(updateTime); + cstmr.setMemo(String.valueOf(data.getRec())); + cstmrService.updateById(cstmr); + } + log.info("====>> 鏇存柊瀹㈡埛璧勬枡锛歿}", data.getUserCode()); + } + + } + } catch (Exception e) { + e.printStackTrace(); + } + } + + /** * 鎸佷箙鍖栭攢鍞鍗� */ // @Scheduled(cron = "0/3 * * * * ? ") diff --git a/src/main/resources/mapper/MatMapper.xml b/src/main/resources/mapper/MatMapper.xml index 6b93176..cc2280a 100644 --- a/src/main/resources/mapper/MatMapper.xml +++ b/src/main/resources/mapper/MatMapper.xml @@ -48,6 +48,6 @@ </select> <select id="selectByMatnr" resultMap="BaseResultMap"> - select * from man_mat where 1=1 and matnr = #{matnr} + select top 1 * from man_mat where 1=1 and matnr = #{matnr} </select> </mapper> -- Gitblit v1.9.1