diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ITSysDictService.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ITSysDictService.java index ccf7c194c7a9a6dcca6fa69db53d76de52974670..d6293caff42c50c519b232e6e469ac949beda8df 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ITSysDictService.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ITSysDictService.java @@ -15,6 +15,8 @@ import com.baomidou.mybatisplus.extension.service.IService; */ public interface ITSysDictService extends IService<TSysDict> { - R getTagDate(TSysDictQuery tSysDictQuery); + R<String> getTagDate(TSysDictQuery tSysDictQuery); + + R<String> getNameByQuery(TSysDictQuery tSysDictQuery); } diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TEquipmentRunServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TEquipmentRunServiceImpl.java index a9deebac9bea56d197cffd4d4bb2bb235dd9e1ef..74fc1e4f33d470f93167fc1338233a05cafff9cd 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TEquipmentRunServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TEquipmentRunServiceImpl.java @@ -112,11 +112,11 @@ public class TEquipmentRunServiceImpl extends ServiceImpl<TEquipmentRunMapper, T equipmentRunMapper.updateById(run); } else { //设置tag - com.baomidou.mybatisplus.extension.api.R r = itSysDictService.getTagDate(null); + com.baomidou.mybatisplus.extension.api.R<String> r = itSysDictService.getTagDate(null); if (r.getCode() != 0) { return R.fail(ResponseEnum.FAIL, r.getMsg()); } - run.setTag((String) r.getData()); + run.setTag(r.getData()); equipmentRunMapper.insert(run); } return R.ok(); diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMaterialOutServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMaterialOutServiceImpl.java index 02a5e2b0c7ad04a64af2ba5f595a4f9a67e9bd59..74c77d48a3800f403b2d9d281fd4e75dad438be7 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMaterialOutServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMaterialOutServiceImpl.java @@ -78,11 +78,11 @@ public class TMaterialOutServiceImpl extends ServiceImpl<TMaterialOutMapper, TMa TMaterialOut out = new TMaterialOut(); BeanUtils.copyProperties(query, out); //è®¾ç½®æ ‡æ³¨æ—¥æœŸ - com.baomidou.mybatisplus.extension.api.R r = itSysDictService.getTagDate(null); + com.baomidou.mybatisplus.extension.api.R<String> r = itSysDictService.getTagDate(null); if (r.getCode() != 0) { return R.fail(ResponseEnum.FAIL, r.getMsg()); } - out.setTag((String) r.getData()); + out.setTag(r.getData()); materialOutMapper.insert(out); return R.ok(); } diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMineWorkemployeesServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMineWorkemployeesServiceImpl.java index ff44d4af325f8267d1b165ae3303bca8564cc85d..c93f15d9f9e43e79b8e02f2a9eb1313dd75a5c95 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMineWorkemployeesServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TMineWorkemployeesServiceImpl.java @@ -100,11 +100,11 @@ public class TMineWorkemployeesServiceImpl extends ServiceImpl<TMineWorkemployee TMineWorkemployees tMineWorkemployees = new TMineWorkemployees(); BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, tMineWorkemployees); //设置tag - R r1 = itSysDictService.getTagDate(null); + R<String> r1 = itSysDictService.getTagDate(null); if (r1.getCode() != 0) { return R.failed(r1.getMsg()); } - tMineWorkemployees.setTag((String) r1.getData()); + tMineWorkemployees.setTag(r1.getData()); //è®¡ç®—ä¸Šçæ€»äººæ•° tMineWorkemployees.setZrs(calculateZrs(tMineWorkemployees)); //ä¿å˜ diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesAuxiliaryServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesAuxiliaryServiceImpl.java index 66971875a6791b38735ebba7ed4845fd01656f8a..08263ae81ffbb3c3fdb895414f6ce1f8a6c52c33 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesAuxiliaryServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesAuxiliaryServiceImpl.java @@ -130,11 +130,11 @@ public class TProcessesAuxiliaryServiceImpl extends ServiceImpl<TProcessesAuxili TProcessesAuxiliary tProcessesAuxiliary = new TProcessesAuxiliary(); BeanUtils.copyProperties(query, tProcessesAuxiliary); //设置tag - R r1 = itSysDictService.getTagDate(null); + R<String> r1 = itSysDictService.getTagDate(null); if (r1.getCode() != 0) { return R.failed(r1.getMsg()); } - tProcessesAuxiliary.setTag((String) r1.getData()); + tProcessesAuxiliary.setTag(r1.getData()); //设置å•耗 if (query.getLjyl() == 0) { tProcessesAuxiliary.setDh(0D); diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastServiceImpl.java index 568ffb79124de5eef38eb3508b13cd35acd97662..efe8e759faafeeb875f570d4aa8bf1c223ce1f5c 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastServiceImpl.java @@ -154,11 +154,11 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe TProcessesBlast tProcessesDrilling = new TProcessesBlast(); BeanUtils.copyProperties(query, tProcessesDrilling); //设置tag - R r1 = itSysDictService.getTagDate(null); + R<String> r1 = itSysDictService.getTagDate(null); if (r1.getCode() != 0) { return R.failed(r1.getMsg()); } - tProcessesDrilling.setTag((String) r1.getData()); + tProcessesDrilling.setTag(r1.getData()); //å¢žåŠ int insert = baseMapper.insert(tProcessesDrilling); if (insert > 0) { diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastdesignHoleServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastdesignHoleServiceImpl.java index 804e46186edf344a245f078ea9264515a994b06c..75ae1021dc39e9cce11e5bda1d0ba58b869f5f9b 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastdesignHoleServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesBlastdesignHoleServiceImpl.java @@ -155,7 +155,7 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses //计算å•å”çˆ†ç ´é‡ calculateHoleBlastVolume(temp); } - //如果修改了å°é˜¶é«˜åº¦ï¼Œéœ€è¦é€šçŸ¥çˆ†ç ´è®¾è®¡é‡æ–°è®¡ç®—è®¾è®¡åŒºçˆ†ç ´é‡ + //如果修改了å°é˜¶é«˜åº¦ï¼Œéœ€è¦é€šçŸ¥ç©¿å”å·¥åºé‡æ–°è®¡ç®—è®¾è®¡åŒºçˆ†ç ´é‡ if (query.getStepHeight() != null) { TProcessesDrillingQuery tProcessesDrillingQuery = new TProcessesDrillingQuery(); tProcessesDrillingQuery.setUid(temp.getUid()); @@ -283,11 +283,11 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses //å•å”çˆ†ç ´é‡(m3)=å”è·*排è·*å°é˜¶é«˜åº¦ calculateHoleBlastVolume(tProcessesBlastdesignHole); //设置tag - R tagDate = itSysDictService.getTagDate(null); + R<String> tagDate = itSysDictService.getTagDate(null); if (tagDate.getCode() != 0) { return R.failed(tagDate.getMsg()); } - tProcessesBlastdesignHole.setTag((String) tagDate.getData()); + tProcessesBlastdesignHole.setTag(tagDate.getData()); //å¢žåŠ log.info(JSON.toJSONString(tProcessesBlastdesignHole)); int insert = baseMapper.insert(tProcessesBlastdesignHole); diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesCrusherServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesCrusherServiceImpl.java index c9d445101bdd88672e1f6bd2f7626a8ac587a717..7bb8a5208bf9b4ea89731fb4149ea182d4f34948 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesCrusherServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesCrusherServiceImpl.java @@ -113,11 +113,11 @@ public class TProcessesCrusherServiceImpl extends ServiceImpl<TProcessesCrusherM TProcessesCrusher tProcessesCrusher = new TProcessesCrusher(); BeanUtils.copyProperties(query, tProcessesCrusher); //è®¾ç½®æ ‡æ³¨æ—¥æœŸ - R r1 = itSysDictService.getTagDate(null); + R<String> r1 = itSysDictService.getTagDate(null); if (r1.getCode() != 0) { return R.failed(r1.getMsg()); } - tProcessesCrusher.setTag((String) r1.getData()); + tProcessesCrusher.setTag(r1.getData()); //å¢žåŠ log.info(JSON.toJSONString(tProcessesCrusher)); int insert = baseMapper.insert(tProcessesCrusher); diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDiggingServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDiggingServiceImpl.java index 417ae53eff0b4366700ccad8fafecbf58ebfffee..fac657b4582b7833c21205da60efe5d1566e18cf 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDiggingServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDiggingServiceImpl.java @@ -117,11 +117,11 @@ public class TProcessesDiggingServiceImpl extends ServiceImpl<TProcessesDiggingM TProcessesDigging digging = new TProcessesDigging(); BeanUtils.copyProperties(query, digging); //设置tag - com.baomidou.mybatisplus.extension.api.R r = itSysDictService.getTagDate(null); + com.baomidou.mybatisplus.extension.api.R<String> r = itSysDictService.getTagDate(null); if (r.getCode() != 0) { return R.fail(ResponseEnum.FAIL, r.getMsg()); } - digging.setTag((String) r.getData()); + digging.setTag(r.getData()); processesDiggingMapper.insert(digging); return R.ok(); } diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDrillingServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDrillingServiceImpl.java index 1beacd353b28cd9860b6732deb05a1190c97e297..04b8712fd6d6daabdf7c03705d7ebd8fbc8c1200 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDrillingServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDrillingServiceImpl.java @@ -93,11 +93,29 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin Double todayDepthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper); - //查询,本月åˆè®¡å”æ·± 上月26æ—¥åˆ°å½“å‰æ—¥æœŸçš„å®žæµ‹å”æ·±ç›¸åŠ + //查询,本月åˆè®¡å”æ·± + //æœ¬å—æ®µéœ€è¦æŸ¥è¯¢å—典表SysDictçš„id为6的数æ®çš„nameå—æ®µï¼Œ + //例如查询出æ¥nameå—æ®µæ˜¯26:上月26æ—¥åˆ°å½“å‰æ—¥æœŸçš„å®žæµ‹å”æ·±ç›¸åŠ + //查询å—å…¸id为6çš„nameå—æ®µ + TSysDictQuery tSysDictQuery = new TSysDictQuery(); + tSysDictQuery.setId(ProjectEnum.TSysDict.SIX.getValue()); + R<String> name = itSysDictService.getNameByQuery(tSysDictQuery); + if (name.getCode() != 0) { + log.error("ç©¿å”å·¥åºä¸->获å–å—å…¸SysDictçš„id为6æ•°æ®çš„nameå—æ®µå¤±è´¥"); + return R.failed(name.getMsg()); + } + //å°†name转化为integer + Integer date; + try { + date = Integer.valueOf(name.getData()); + } catch (Exception e) { + e.printStackTrace(); + return R.failed("ç©¿å”å·¥åºä¸->nameå—æ®µè½¬åŒ–为integer失败,nameä¸ä¸ºæ•°å—"); + } //åˆå§‹åŒ–QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper - .ge(drillingDate.toString(), DateUtil.getBeginTimeStr(LocalDateTime.now().minusMonths(1).withDayOfMonth(26))) + .ge(drillingDate.toString(), DateUtil.getBeginTimeStr(LocalDateTime.now().minusMonths(1).withDayOfMonth(date))) .le(drillingDate.toString(), DateUtil.getEndTimeStr(LocalDateTime.now())); Double monthDepthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper); @@ -117,11 +135,11 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin TProcessesDrilling tProcessesDrilling = new TProcessesDrilling(); BeanUtils.copyProperties(query, tProcessesDrilling); //设置tag - R r1 = itSysDictService.getTagDate(null); + R<String> r1 = itSysDictService.getTagDate(null); if (r1.getCode() != 0) { return R.failed(r1.getMsg()); } - tProcessesDrilling.setTag((String) r1.getData()); + tProcessesDrilling.setTag(r1.getData()); //å¢žåŠ int insert = baseMapper.insert(tProcessesDrilling); if (insert > 0) { diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesTruckServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesTruckServiceImpl.java index 8cc41c561fd69508132132901875140c13876603..e12cdd50d2ed594caabe7a8ea9ba7ea78f38079f 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesTruckServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesTruckServiceImpl.java @@ -111,11 +111,11 @@ public class TProcessesTruckServiceImpl extends ServiceImpl<TProcessesTruckMappe } TProcessesTruck truck = new TProcessesTruck(); BeanUtils.copyProperties(query, truck); - com.baomidou.mybatisplus.extension.api.R r = itSysDictService.getTagDate(null); + com.baomidou.mybatisplus.extension.api.R<String> r = itSysDictService.getTagDate(null); if (r.getCode()!=0){ return R.fail(ResponseEnum.FAIL,r.getMsg()); } - truck.setTag((String) r.getData()); + truck.setTag(r.getData()); processesTruckMapper.insert(truck); return R.ok(); } diff --git a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TSysDictServiceImpl.java b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TSysDictServiceImpl.java index 82560c9936cef2172a50c46ba9fee60e77942203..ed9573a982bb7854cdd7628fcb28987d225ab1c0 100644 --- a/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TSysDictServiceImpl.java +++ b/acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TSysDictServiceImpl.java @@ -6,8 +6,11 @@ import cn.wise.sc.acquisition.business.mapper.TSysDictMapper; import cn.wise.sc.acquisition.business.model.query.TSysDictQuery; import cn.wise.sc.acquisition.business.service.ITSysDictService; import cn.wise.sc.acquisition.business.util.DateUtil; +import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.api.R; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; @@ -22,6 +25,7 @@ import java.time.LocalDateTime; * @since 2021-04-23 */ @Service +@Slf4j public class TSysDictServiceImpl extends ServiceImpl<TSysDictMapper, TSysDict> implements ITSysDictService { /** @@ -32,7 +36,8 @@ public class TSysDictServiceImpl extends ServiceImpl<TSysDictMapper, TSysDict> i * @return */ @Override - public R getTagDate(TSysDictQuery tSysDictQuery) { + public R<String> getTagDate(TSysDictQuery tSysDictQuery) { + log.info(JSON.toJSONString(tSysDictQuery)); //èŽ·å–æ ‡æ³¨æ—¥æœŸï¼Œå°†å—å…¸ä¸id为6的数æ®çš„nameå—æ®µåšæ¯”è¾ƒ //大于nameå—æ®µè®°å½•下一个月,å°äºŽè¯¥å—段记录本月 //获å–id为6çš„å—å…¸ @@ -63,4 +68,24 @@ public class TSysDictServiceImpl extends ServiceImpl<TSysDictMapper, TSysDict> i } } + @Override + public R<String> getNameByQuery(TSysDictQuery query) { + log.info(JSON.toJSONString(query)); + //傿•°æ ¡éªŒ + //å°è£… + QueryWrapper<TSysDict> queryWrapper = new QueryWrapper<>(); + queryWrapper.eq(query.getId() != null, ProjectEnum.TSysDict.ID.getLabel(), query.getId()); + //查询 + TSysDict tSysDict = baseMapper.selectOne(queryWrapper); + if (tSysDict == null) { + log.error("æ•°æ®å—å…¸ä¸->æ ¹æ®æ¡ä»¶èŽ·å–æ•°æ®ï¼Œæ•°æ®ä¸ºç©º:{}", JSON.toJSONString(query)); + return R.failed("æ•°æ®å—å…¸ä¸->æ ¹æ®æ¡ä»¶èŽ·å–æ•°æ®ï¼Œæ•°æ®ä¸ºç©º"); + } + if (StringUtils.isBlank(tSysDict.getName())) { + log.error("æ•°æ®å—å…¸ä¸->æ ¹æ®æ¡ä»¶èŽ·å–æ•°æ®ï¼Œnameå—æ®µä¸ºç©º:{}", JSON.toJSONString(query)); + return R.failed("æ•°æ®å—å…¸ä¸->æ ¹æ®æ¡ä»¶èŽ·å–æ•°æ®ï¼Œnameå—æ®µä¸ºç©º"); + } + return R.ok(tSysDict.getName()); + } + }