楚江ERP：合同规范补充提醒

@@ -55,6 +55,7 @@ import org.apache.poi.hssf.usermodel.HSSFWorkbook;
 import org.apache.poi.ss.usermodel.*;
 import org.apache.poi.util.IOUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -613,6 +614,14 @@ public class ContractDistributorStandardController extends DefaultBaseController
         return InvokeResultBuilder.success();
     }
 
+    @ApiModelProperty("合同规范补充提醒")
+    @GetMapping("/supplementContractSpecReminder")
+    @Scheduled(cron = "0 20 0 * * ?")
+    public InvokeResult<Void> supplementContractSpecReminder() {
+        contractDistributorStandardService.supplementContractSpecReminder();
+        return InvokeResultBuilder.success();
+    }
+
     /**
      * 标准合同模版打印
      */

@@ -9,9 +9,14 @@ import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
 import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
 import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
 import com.lframework.starter.common.utils.StringUtil;
+import com.lframework.starter.mq.core.service.MqProducerService;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
+import com.lframework.starter.web.inner.dto.message.SysSiteMessageDto;
 import com.lframework.starter.web.inner.entity.SysDataDicItem;
 import com.lframework.starter.web.inner.service.system.SysDataDicItemService;
+import com.lframework.starter.web.inner.service.system.SysUserRoleService;
+import com.lframework.xingyun.basedata.entity.Workshop;
+import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
 import com.lframework.xingyun.sc.controller.contract.ContractDistributorStandardController;
 import com.lframework.xingyun.sc.entity.*;
 import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
@@ -81,6 +86,12 @@ public class ContractDistributorStandardServiceImpl extends
     private ContractFrameworkService contractFrameworkService;
     @Resource
     private SysDataDicItemService sysDataDicItemService;
+    @Resource
+    private SysUserRoleService sysUserRoleService;
+    @Resource
+    private WorkshopService workshopService;
+    @Autowired
+    private MqProducerService mqProducerService;
 
     @Override
     public PageResult<ContractDistributorStandard> query(Integer pageIndex, Integer pageSize, QueryContractDistributorStandardVo vo) {
@@ -1037,6 +1048,112 @@ public class ContractDistributorStandardServiceImpl extends
         return getBaseMapper().getContractSigned(buyerList);
     }
 
+    @Override
+    public void supplementContractSpecReminder() {
+        Wrapper<ContractDistributorStandard> wrapper = Wrappers.lambdaQuery(ContractDistributorStandard.class)
+                .in(ContractDistributorStandard::getFormalApproved, Arrays.asList("REFUSE", "CANCEL"))
+                .or()
+                .in(ContractDistributorStandard::getStandardApproved, Arrays.asList("REFUSE", "CANCEL"));
+        List<ContractDistributorStandard> contractDistributorStandardList = list(wrapper);
+        if (CollectionUtils.isEmpty(contractDistributorStandardList)) {
+            return;
+        }
+
+        Set<String> workshopIds = contractDistributorStandardList
+                .stream()
+                .map(ContractDistributorStandard::getWorkshopId)
+                .collect(Collectors.toSet());
+        List<Workshop> workshopList = workshopService.listByIds(workshopIds);
+        Map<String, String> workshopIdAndCodeMap = CollectionUtils.emptyIfNull(workshopList)
+                .stream()
+                .collect(Collectors.toMap(Workshop::getId, Workshop::getCode));
+        Map<String, String> workshopCodeAndJybzgCodeMap = new HashMap<>(4);
+        workshopCodeAndJybzgCodeMap.put("yfc", "yfcjybzg"); // 一分厂
+        workshopCodeAndJybzgCodeMap.put("efc", "efcjybzg"); // 二分厂
+        workshopCodeAndJybzgCodeMap.put("sfc", "sfcjybzg"); // 三分厂
+        workshopCodeAndJybzgCodeMap.put("ztfc", "ztcjybzg"); // 四分厂
+        Map<String, List<String>> jybzgCodeAndUserIdMap = new HashMap<>(4);
+        jybzgCodeAndUserIdMap.put("yfcjybzg", sysUserRoleService.listUserIdByRoleCodes(Collections.singletonList("yfcjybzg")));
+        jybzgCodeAndUserIdMap.put("efcjybzg", sysUserRoleService.listUserIdByRoleCodes(Collections.singletonList("efcjybzg")));
+        jybzgCodeAndUserIdMap.put("sfcjybzg", sysUserRoleService.listUserIdByRoleCodes(Collections.singletonList("sfcjybzg")));
+        jybzgCodeAndUserIdMap.put("ztcjybzg", sysUserRoleService.listUserIdByRoleCodes(Collections.singletonList("ztcjybzg")));
+
+        List<String> bsczgUserIdList = sysUserRoleService.listUserIdByRoleCodes(Collections.singletonList("bsczg"));
+        contractDistributorStandardList.forEach(contractDistributorStandard -> {
+            try {
+                StringBuilder stringBuilder = new StringBuilder("您的");
+                if ("DISTRIB_STD".equals(contractDistributorStandard.getType())) {
+                    stringBuilder.append("经销标准合同");
+                } else if ("DIST_STOCK_CONTRACT".equals(contractDistributorStandard.getType())) {
+                    stringBuilder.append("经销库存合同");
+                } else if ("DRAFT_DIST_AGMT".equals(contractDistributorStandard.getType())) {
+                    stringBuilder.append("经销未锁规合同");
+                } else if ("INTL_STD_CONTRACT".equals(contractDistributorStandard.getType())) {
+                    stringBuilder.append("外贸标准合同");
+                } else if ("INTL_INVENTORY_AGMT".equals(contractDistributorStandard.getType())) {
+                    stringBuilder.append("外贸库存合同");
+                } else if ("INTL_OPEN_SPEC_AGMT".equals(contractDistributorStandard.getType())) {
+                    stringBuilder.append("外贸未锁规格合同");
+                } else if ("PROCESS_STD_AGMT".equals(contractDistributorStandard.getType())) {
+                    stringBuilder.append("加工标准合同");
+                }
+
+                stringBuilder.append("（");
+                LocalDate lastApprovedTime = LocalDate.now();
+                if ("FORMAL".equals(contractDistributorStandard.getStatus())) {
+                    if (!"REFUSE".equals(contractDistributorStandard.getFormalApproved())
+                            && !"CANCEL".equals(contractDistributorStandard.getFormalApproved())) {
+                        return;
+                    }
+
+                    stringBuilder.append("正式合同）");
+                    lastApprovedTime = contractDistributorStandard.getFormalTime().toLocalDate();
+                }
+
+                if ("STANDARD".equals(contractDistributorStandard.getStatus())) {
+                    if (!"REFUSE".equals(contractDistributorStandard.getStandardApproved())
+                            && !"CANCEL".equals(contractDistributorStandard.getStandardApproved())) {
+                        return;
+                    }
+
+                    stringBuilder.append("标准合同）");
+                    lastApprovedTime = contractDistributorStandard.getStandardTime().toLocalDate();
+                }
+
+                stringBuilder.append("，合同号：").append(contractDistributorStandard.getCode());
+                stringBuilder.append("，请尽快补充规范合同。");
+                List<String> userIdList = new ArrayList<>();
+                userIdList.add(contractDistributorStandard.getCreateById());
+
+                LocalDate currentDate = LocalDate.now();
+                // 如果最后批准时间加3天还在当前时间之前，说明超过3天
+                if (lastApprovedTime.plusDays(3).isBefore(currentDate)) {
+                    Optional.ofNullable(contractDistributorStandard.getWorkshopId())
+                            .map(workshopIdAndCodeMap::get)
+                            .filter(StringUtils::isNotBlank)
+                            .map(workshopCodeAndJybzgCodeMap::get)
+                            .filter(StringUtils::isNotBlank)
+                            .map(jybzgCodeAndUserIdMap::get)
+                            .ifPresent(userIdList::addAll);
+
+                    userIdList.addAll(bsczgUserIdList);
+                }
+
+                // 发送消息
+                SysSiteMessageDto messageDto = new SysSiteMessageDto();
+                messageDto.setUserIdList(userIdList);
+                messageDto.setTitle("补充规范合同通知");
+                messageDto.setContent(stringBuilder.toString());
+                messageDto.setBizKey(IdUtil.getId());
+                messageDto.setCreateUserId(null);
+
+                mqProducerService.createSysSiteMessage(messageDto);
+            } catch (Exception e) {
+                log.error("发送消息报错", e);
+            }
+        });
+    }
+
     @CacheEvict(value = ContractDistributorStandard.CACHE_NAME, key = "@cacheVariables.tenantId() + #key")
     @Override
     public void cleanCacheByKey(Serializable key) {

@@ -120,4 +120,9 @@ public interface ContractDistributorStandardService extends BaseMpService<Contra
      * @return 一年内未签订合同的企业
      */
     List<String> getContractSigned(List<String> buyerList);
+
+    /**
+     * 合同规范补充提醒
+     */
+    void supplementContractSpecReminder();
 }