flower_city/src/main/java/com/dg/core/db/gen/mapper/OrganizationChartMapper.java
@@ -64,7 +64,7 @@ /** * 根据所属地区查找部门 */ List<OrganizationChartEntity> selectByCode(@Param("id")String id, @Param("areaCode") String areaCode); List<OrganizationChartEntity> selectByCode(@Param("id")String id, @Param("areaCode") String areaCode,@Param("grade") Integer grade); flower_city/src/main/java/com/dg/core/service/impl/GuideRepairOrderServiceImpl.java
@@ -51,6 +51,10 @@ @Resource private AreaCode2022Mapper areaCode2022Mapper; @Resource SmsUtil smsUtil; @Resource(name = "stringRedisTemplate") @@ -84,8 +88,13 @@ } } if (isAdd) { AreaCode2022 areaCode2022 = areaCode2022Mapper.selectOne(new QueryWrapper<AreaCode2022>().lambda().eq(AreaCode2022::getCode, guideRepairOrder.getAreaCode())); Integer grade=2; if (areaCode2022.getLevel()==2){ grade=1; } //自动分配业务代码开始 List<OrganizationChartEntity> organizationChartEntities = organizationChartMapper.selectByCode(transactionEvent.getDepartmentId(), guideRepairOrder.getAreaCode()); List<OrganizationChartEntity> organizationChartEntities = organizationChartMapper.selectByCode(transactionEvent.getDepartmentId(), guideRepairOrder.getAreaCode(),grade); if (organizationChartEntities.size() > 0) { for (OrganizationChartEntity organizationChart : organizationChartEntities) { departmentIds.add(organizationChart.getId().toString()); @@ -407,9 +416,9 @@ if (sysUsers != null && sysUsers.size() > 0) { for (SysUser sysUser : sysUsers) { // transactionEventMapper.selectOne(new QueryWrapper<TransactionEvent>().lambda().eq(TransactionEvent::getId, guideRepairOrder.getMatterId())); // SysUser sysUser = sysUserMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId, guideRepairOrder.getGuideUserId())); SysUser sysUserGuideUser = sysUserMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId, guideRepairOrder.getGuideUserId())); if (sysUser != null) { smsUtil.sendSmsOvertimeNew(sysUser.getPhonenumber(), sysUser.getUserName()); smsUtil.sendSmsOvertimeNew(sysUser.getPhonenumber(), sysUserGuideUser.getUserName()); wxUtil.sendGuideRepairOrderOvertime(sysUser.getOpenid(), accessToken, "86JgWHhR8b1XxD72WYqMnndyfkiMtSSoCk9NFMwLEZ8", sysUser); guideRepairOrder.setIsPush(1); guideRepairOrder.setIsTimeout("2"); flower_city/src/main/java/com/dg/core/util/SmsUtil.java
@@ -23,6 +23,8 @@ import javax.annotation.Resource; import java.io.IOException; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.HashMap; import java.util.Map; import java.util.Random; @@ -127,10 +129,10 @@ response = client.newCall(request).execute(); redisTemplate.opsForValue().set(tel, code + "", 5, TimeUnit.MINUTES); // rsa = response.body().string().split("|")[0]; rsa = response.message(); if (!rsa.equals("OK")){ return ResultData.success("短信发送失败"); } rsa = response.message(); if (!rsa.equals("OK")){ return ResultData.success("短信发送失败"); } } catch (IOException e) { e.printStackTrace(); return ResultData.success("短信发送失败"); @@ -175,7 +177,7 @@ try { HashMap<String, Object> m = mapper.readValue(rs.getData().toString(), HashMap.class); if (m.get("Message").equals("OK")) { return ResultData.success("短信发送成功!"); return ResultData.success("短信发送成功!"); } } catch (JsonProcessingException e) { e.printStackTrace(); @@ -376,7 +378,7 @@ String url = "https://dxsdk.028lk.com:8082/Api/SendSms?"+"LoginName="+LoginName+"&Pwd="+Pwd+"&FeeType="+FeeType+"&Mobile="+tel+"&Content="; Random rd = new Random(); String content="您有新的导办工单,请"+name+"尽快处理。"; String content="您在"+ LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) +"收到新的导办工单,请"+name+"尽快处理。"; url=url+content; OkHttpClient client = new OkHttpClient(); Response response;