hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/hiddenDanger/service/impl/HiddenDangerServiceImpl.java
@@ -102,10 +102,20 @@ } PageHelper.startPage(pageNum,pageSize); List<HiddenDangerEntity> hiddenDangerEntities = new ArrayList<>(); if(type == 1){ if(type == 1){//审核列表 if (sysUserInfo.getUserType() == 2){ map.put("createUser",sysUserInfo.getUserId()); } //小程序 待审核排前面 待审核按时间正序 审核成功的倒叙 hiddenDangerEntities = hiddenDangerMapper.selectAppList(map); }else { }else if(type == 2){//隐患举报详情列表 if (sysUserInfo.getUserType() == 2){ map.put("createUser",sysUserInfo.getUserId()); } //小程序 待审核排前面 待审核按时间正序 审核成功的倒叙 hiddenDangerEntities = hiddenDangerMapper.selectPageList(map); } else { //web 按时间倒序 hiddenDangerEntities = hiddenDangerMapper.selectPageList(map); } @@ -160,12 +170,10 @@ } @Override @Transactional(rollbackFor = Exception.class) public BasicResult examine(HiddenDangerEntity hiddenDangerEntity) { SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo(); String platUserId = regionInspectionRecordMapper.selectPlatUserId(hiddenDangerEntity.getCreateUser()); Map platUser = regionInspectionRecordMapper.getPlatUser(platUserId); Integer user_type = (int)platUser.get("user_type"); Map account = new HashMap(); account.put("userId",platUserId); @@ -178,12 +186,16 @@ totalIntegral = queryAccount.getTotalIntegral();//当前余额 } hiddenDangerEntity.setAuditStatus(1);//1审核通过 hiddenDangerEntity.setDangerLocation(null); synchronized (Lock){ hiddenDangerMapper.update(hiddenDangerEntity); IntegralAccountEntity integralAccountEntity = IntegralAccountEntity .builder() .userId(platUserId) .id(UUIDUtils.create()) .accumulateIntegral(accumulateIntegral+hiddenDangerEntity.getIntegral()) .totalIntegral(totalIntegral+hiddenDangerEntity.getIntegral()) .userType(sysUserInfo.getUserType()) .build(); IntegralDetailEntity integralDetailEntity = IntegralDetailEntity @@ -194,11 +206,16 @@ .integralWater(hiddenDangerEntity.getIntegral()) .createTime(new Date()) .createUser(sysUserInfo.getUserId()) .userType(user_type) .userType(sysUserInfo.getUserType()) .userId(platUserId) .type(1) .remark("隐患审核") .companyId(sysUserInfo.getCompanyId()) .build(); integralDetailMapper.insertAndUpdateAccount(integralAccountEntity); integralDetailMapper.insertDetailAndUpdate(integralDetailEntity); } return BasicResult.success(); } } hd/pipe/secure/src/main/java/com/thhy/secure/modules/biz/integralAccount/service/impl/IntegralDetailServiceImpl.java
@@ -33,6 +33,7 @@ @Autowired private IntegralDetailMapper integralDetailMapper; private static final Object Lock= new Object(); /** * 积分超市新增和修改 * @param integralDetailEntity @@ -45,6 +46,7 @@ String sysUserId = sysUserInfo.getUserId(); String companyId = sysUserInfo.getCompanyId(); //扣积分逻辑 synchronized (Lock){ IntegralAccountEntity integralAccountEntity = IntegralAccountEntity .builder() .userId(integralDetailEntity.getUserId()) @@ -81,6 +83,7 @@ integralDetailEntity.setIntegralSource("积分超市"); //添加或修改明细 integralDetailMapper.insertDetailAndUpdate(integralDetailEntity); } return BasicResult.success(); } @@ -121,7 +124,7 @@ Double totalConsumption = queryAccount.getTotalConsumption();//总消耗 Double accumulateIntegral = queryAccount.getAccumulateIntegral();//累计积分 Double totalIntegral = queryAccount.getTotalIntegral();//当前余额 synchronized (Lock){ IntegralAccountEntity integralAccountEntity = IntegralAccountEntity .builder() .userId(integralDetailEntity.getUserId()) @@ -131,6 +134,7 @@ .build(); integralDetailMapper.insertAndUpdateAccount(integralAccountEntity); integralDetailMapper.delete(id); } return BasicResult.success(); }
@@ -149,7 +149,9 @@ t.companyId, t.level, t.integral, su.real_name reporter su.real_name reporter, t.integral, t.level from t_hidden_danger t LEFT JOIN sys_users su ON su.user_id = t.createUser LEFT JOIN sys_users su1 ON su1.user_id = t.updateUser @@ -184,6 +186,9 @@ <if test="startTime!= null and endTime!=null and startTime != '' and endTime !=''"> and t.createTime BETWEEN #{startTime} and #{endTime} </if> <if test="createUser!= null and createUser != ''"> and t.createUser =#{createUser} </if> order by t.createTime desc </select> @@ -214,6 +219,9 @@ <if test="startTime!= null and endTime!=null and startTime != '' and endTime !=''"> and t.createTime BETWEEN #{startTime} and #{endTime} </if> <if test="createUser!= null and createUser != ''"> and t.createUser =#{createUser} </if> ORDER BY t.auditStatus, case when t.auditStatus = 0 then t.createTime END, hd/pipe/secure/src/main/resources/mapping/IntegralDetailMapper.xml
@@ -275,6 +275,7 @@ <if test="startTime != null and startTime != '' and endTime !=null and endTime !=''"> AND t.createTime BETWEEN #{startTime} and #{endTime} </if> order by t.createTime desc </select> <select id="selectByOne" resultType="com.thhy.secure.modules.biz.integralAccount.entity.IntegralAccountEntity"> SELECT
