blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2023-11-07 54beb665319b66742cdec3dffb7e298701d61582 
 screen-api/src/main/java/com/moral/api/service/impl/UserServiceImpl.java


@@ -11,14 +11,18 @@


import com.moral.api.entity.*;


import com.moral.api.mapper.*;


import com.moral.api.pojo.bo.UserBO;


import com.moral.api.pojo.enums.AllocationApproveEnum;


import com.moral.api.pojo.enums.FileTableEnum;


import com.moral.api.pojo.enums.StateEnum;


import com.moral.api.pojo.enums.SysDictTypeEnum;


import com.moral.api.pojo.query.app.AppAllocationPushUserCond;


import com.moral.api.pojo.vo.file.FileVo;


import com.moral.api.service.FileTableService;


import com.moral.api.service.ResponsibilityUnitService;


import com.moral.api.service.UserService;


import com.moral.api.utils.OperationLogUtils;


import com.moral.api.utils.WechatUtils;


import com.moral.api.vo.WxMssVo;


import com.moral.constant.Constants;


import com.moral.constant.ResponseCodeEnum;


import com.moral.util.*;


@@ -26,9 +30,12 @@


import org.apache.commons.collections4.CollectionUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.http.ResponseEntity;


import org.springframework.scheduling.annotation.Async;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.ObjectUtils;


import org.springframework.web.client.RestTemplate;


import org.springframework.web.context.request.RequestContextHolder;


import org.springframework.web.context.request.ServletRequestAttributes;




@@ -226,6 +233,72 @@


        sysLog(userId+"退出了小程序",user);


        return true;


    }






     @Autowired


     private ResponsibilityUnitService responsibilityUnitService;


    /**


     * 小程序推送


     * @param appAllocationPushUserCond


     */


    @Override


    @Async


    public void pushOneUser(AppAllocationPushUserCond appAllocationPushUserCond) {




        ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(appAllocationPushUserCond.getUnitId());


        Integer areaCode = responsibilityUnit.getAreaCode();




        List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitService.selectAreaUnit(areaCode.toString().length()>6?responsibilityUnit.getParentCode():responsibilityUnit.getAreaCode());


        //获取unitid


        LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<>();


        wrapper.eq(User::getIsDelete,Constants.NOT_DELETE);


        Integer state = appAllocationPushUserCond.getState();


        if (state==20){


            wrapper.eq(User::getUnitId,appAllocationPushUserCond.getUnitId());


        }else {


            wrapper.eq(User::getUnitId,ObjectUtils.isEmpty(responsibilityUnits)?0:responsibilityUnits.get(0).getUnitId());


        }




        List<User> users = userMapper.selectList(wrapper);


        if (ObjectUtils.isEmpty(users)){


            return;


        }




        String dateString = DateUtils.dateToDateString(appAllocationPushUserCond.getEscalationTime(),"MM月dd日");


        //这里简单起见我们每次都获取最新的access_token（时间开发中，应该在access_token快过期时再重新获取）


        //小程序订阅


        String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + WechatUtils.getAccessToken();


        //发送消息


        for (User user : users) {


            RestTemplate restTemplate = new RestTemplate();


            //拼接推送的模版


            WxMssVo wxMssVo = new WxMssVo();


            wxMssVo.setTouser(user.getOpenId());//用户的openid（要发送给那个用户，通常这里应该动态传进来的）


            wxMssVo.setTemplate_id("YNqUZ1MgMvwY3G-NENVbcmIBR5dUotSdnwcz96CWrho");//订阅消息模板id


            wxMssVo.setLang("zh_CN");


            wxMssVo.setMiniprogramState("formal");


//        wxMssVo.setPage("pages/index/index");


            Map<String, Object> m = new HashMap<>();


            HashMap<String, Object> map1 = new HashMap<>();


            HashMap<String, Object> map2 = new HashMap<>();


            HashMap<String, Object> map3 = new HashMap<>();


            HashMap<String, Object> map4 = new HashMap<>();


            map1.put("value",responsibilityUnit.getUnitName()+dateString+"的交办单");


            map2.put("value",appAllocationPushUserCond.getAllocationNum());


            map3.put("value",state==30? AllocationApproveEnum.IN_APPROVAL.name:AllocationApproveEnum.UNDER_RECTIFICATION.name);


            map4.put("value",DateUtils.dateToDateString(new Date(),"yyyy年MM月dd日"));


            m.put("thing18", map1);


            m.put("character_string1", map2);


            m.put("thing2", map3);


            m.put("date4", map4);


            wxMssVo.setData(JSON.toJSON(m));


            ResponseEntity<String> responseEntity =


                    restTemplate.postForEntity(url, wxMssVo, String.class);


            String body = responseEntity.getBody();


            log.info("信息:"+body+"账号:"+user.getUserName());


        }


    }




    private void sysLog(String cont,User user){


        //日志


        HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();