获取审核文案

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/impl/TranSettlementReportServiceImpl.java

@@ -783,6 +783,13 @@ public class TranSettlementReportServiceImpl extends ServiceImpl<TranSettlementR
             expenseInfo.setAgent(AuthSecurityUtils.getStaffById(AuthSecurityUtils.getCurrentUserId()).getStaffName());
             expenseInfo.setUnallocatedAmount(money);
             expenseInfoService.insert(expenseInfo);
+            for (TranSettlementReport tranSettlementReport1 : tranSettlementReportList) {
+                tranSettlementReport1.setExpenseId(expenseInfo.getId());
+                tranSettlementReport1.setRequestDate(new Date());
+                tranSettlementReport1.setRequester(AuthSecurityUtils.getStaffById(AuthSecurityUtils.getCurrentUserId()).getStaffName());
+//                tranSettlementReport1.setBatchId(batchReviewInfo.getId());
+                this.updateById(tranSettlementReport1);
+            }
             // 插入操作历史
             String staffName = this.billOperateHisService.getStaffAndName();
             // 插入操作历史
@@ -810,13 +817,6 @@ public class TranSettlementReportServiceImpl extends ServiceImpl<TranSettlementR
                 expenseInfoService.updateById(expenseInfo);
                 workflowService.activateInstance(expenseInfo.getWorkflowId(), expenseInfo.getId());
             }
-            for (TranSettlementReport tranSettlementReport1 : tranSettlementReportList) {
-                tranSettlementReport1.setExpenseId(expenseInfo.getId());
-                tranSettlementReport1.setRequestDate(new Date());
-                tranSettlementReport1.setRequester(AuthSecurityUtils.getStaffById(AuthSecurityUtils.getCurrentUserId()).getStaffName());
-//                tranSettlementReport1.setBatchId(batchReviewInfo.getId());
-                this.updateById(tranSettlementReport1);
-            }
             //  添加提交历史
             CommonBillOperateHis commonBillOperateHis = new CommonBillOperateHis();
             commonBillOperateHis.setBillId(expenseInfo.getId());

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/AcquisitionProvider.java

@@ -0,0 +1,60 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.winsea.svc.base.security.util.AuthSecurityUtils;
+import com.yh.saas.plugin.yiliangyiyun.entity.GeneralAuditInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.PurchasePrice;
+import com.yh.saas.plugin.yiliangyiyun.service.IPurchasePriceService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("procurementPriceApprove")
+public class AcquisitionProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IPurchasePriceService purchasePriceService;
+
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的收购价格调整等待您的审核，{1}{2}收购价格调整。";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        PurchasePrice info = purchasePriceService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getWarehouseName(),info.getGoodsName());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/BukaProvider.java

@@ -0,0 +1,58 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.ClockInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.IClockInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("bukaApprove")
+public class BukaProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IClockInfoService clockInfoService;
+
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的补卡申请等待您的审核。";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        ClockInfo info = clockInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/BuyContractProvider.java

@@ -0,0 +1,66 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractGoodsInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractManagementInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractGoodsInfoService;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractManagementInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("buyContractApprove")
+public class BuyContractProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IContractManagementInfoService contractManagementInfoService;
+    @Autowired
+    private IContractGoodsInfoService contractGoodsInfoService;
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的{1}等待您的审核，合同编号:{2},{3}{4}吨";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        ContractManagementInfo info = contractManagementInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+        ContractGoodsInfo goodsInfo = contractGoodsInfoService.selectOne(new EntityWrapper<ContractGoodsInfo>()
+            .eq("contract_id",businessId));
+        if (goodsInfo == null) {
+            return null;
+        }
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getAgreementType(), info.getContractNo(),goodsInfo.getGoodsName(),info.getWeight());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/DcContractProider.java

@@ -0,0 +1,66 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractGoodsInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractManagementInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractGoodsInfoService;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractManagementInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("daichuContractApprove")
+public class DcContractProider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IContractManagementInfoService contractManagementInfoService;
+    @Autowired
+    private IContractGoodsInfoService contractGoodsInfoService;
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的{1}等待您的审核，合同编号{2},{3}{4}吨";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        ContractManagementInfo info = contractManagementInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+        ContractGoodsInfo goodsInfo = contractGoodsInfoService.selectOne(new EntityWrapper<ContractGoodsInfo>()
+                .eq("contract_id",businessId));
+        if (goodsInfo == null) {
+            return null;
+        }
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getAgreementType(), info.getContractNo(),goodsInfo.getGoodsName(),info.getWeight());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/DsContractProvider.java

@@ -0,0 +1,67 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractGoodsInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractManagementInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractGoodsInfoService;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractManagementInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("daishouContractApprove")
+public class DsContractProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IContractManagementInfoService contractManagementInfoService;
+    @Autowired
+    private IContractGoodsInfoService contractGoodsInfoService;
+
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的{1}等待您的审核，合同编号:{2},{3}{4}吨";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        ContractManagementInfo info = contractManagementInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+        ContractGoodsInfo goodsInfo = contractGoodsInfoService.selectOne(new EntityWrapper<ContractGoodsInfo>()
+                .eq("contract_id",businessId));
+        if (goodsInfo == null) {
+            return null;
+        }
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getAgreementType(), info.getContractNo(),goodsInfo.getGoodsName(),info.getWeight());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/ExepenseYunProvider.java

@@ -0,0 +1,64 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.ExpenseInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.TranSettlementReport;
+import com.yh.saas.plugin.yiliangyiyun.service.IExpenseInfoService;
+import org.springframework.stereotype.Component;
+import com.yh.saas.plugin.yiliangyiyun.service.ITranSettlementReportService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.text.MessageFormat;
+import java.util.List;
+
+@Component("feiyongyunfeiApprove")
+public class ExepenseYunProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+    @Autowired
+    private ITranSettlementReportService tranSettlementReportService;
+    @Autowired
+    private IExpenseInfoService expenseInfoService;
+    // 工作通知信息
+    static final String MESSAGE_CONTENT_CAR = "{0}发起的汽运结算等待您的审核，运费金额{1}元。";
+    static final String MESSAGE_CONTENT_SHIP = "{0}发起的船运结算等待您的审核，运费金额{1}元。";
+    static final String MESSAGE_CONTENT_FIRE = "{0}发起的火运结算等待您的审核，运费金额{1}元。";
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        ExpenseInfo info = expenseInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+        List<TranSettlementReport> list = tranSettlementReportService.selectList(new EntityWrapper<TranSettlementReport>()
+                .eq("expense_id",businessId));
+        if (list == null) {
+            return null;
+        }
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+
+        //汽运
+        if ("1".equals(list.get(0).getTranTypeKey())) {
+            return MessageFormat.format(MESSAGE_CONTENT_CAR, commitUserInfo.getStaffName(), info.getAmountMoney());
+        }
+        //火运
+        else if ("2".equals(list.get(0).getTranTypeKey())) {
+            return MessageFormat.format(MESSAGE_CONTENT_FIRE, commitUserInfo.getStaffName(), info.getAmountMoney());
+        }
+        //船运
+        else {
+            return MessageFormat.format(MESSAGE_CONTENT_SHIP, commitUserInfo.getStaffName(), info.getAmountMoney());
+        }
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/FuelFingProvider.java

@@ -0,0 +1,57 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.FuelFillingInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.IFuelFillingInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("jiayouShenheApprove")
+public class FuelFingProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IFuelFillingInfoService fuelFillingInfoService;
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的发起的加油申请等待您的审核，耗油{1}升，金额{2}元";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        FuelFillingInfo info = fuelFillingInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getTfc(),info.getTotalCost());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/InOutWharehoseTaskProvider.java

@@ -0,0 +1,80 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.InOutWarehouseTask;
+import com.yh.saas.plugin.yiliangyiyun.service.IInOutWarehouseTaskService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("inouttaskTaskApprove")
+public class InOutWharehoseTaskProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IInOutWarehouseTaskService inOutWarehouseTaskService;
+
+    // 工作通知信息
+    static final String MESSAGE_CONTENT_OUT = "{0}发起的出库任务等待您的审核，{1}出库{2}{3}吨";
+    // 工作通知信息
+    static final String MESSAGE_CONTENT_IN = "{0}发起的入库任务等待您的审核，{1}入库{2}{3}吨";
+    // 工作通知信息
+    static final String MESSAGE_CONTENT_MOVE = "{0}发起的移库任务等待您的审核，{1}移库{2}{3}吨";
+    // 工作通知信息
+    static final String MESSAGE_CONTENT_RETURN = "{0}发起的退库并出库任务等待您的审核，{1}{2}吨";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        InOutWarehouseTask info = inOutWarehouseTaskService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        //入库任务
+        if("2".equals(info.getTaskTypeKey())){
+            return MessageFormat.format(MESSAGE_CONTENT_IN, commitUserInfo.getStaffName(),info.getWarehouseName(), info.getGoodsName(),info.getWeight());
+        }
+        //出库
+        else if("1".equals(info.getTaskTypeKey())){
+            return MessageFormat.format(MESSAGE_CONTENT_OUT, commitUserInfo.getStaffName(),info.getWarehouseName(), info.getGoodsName(),info.getWeight());
+        }
+        //移库
+        else if("3".equals(info.getTaskTypeKey())){
+            return MessageFormat.format(MESSAGE_CONTENT_MOVE, commitUserInfo.getStaffName(),info.getWarehouseName(), info.getGoodsName(),info.getWeight());
+        }
+        //退库并出库
+        else{
+            return MessageFormat.format(MESSAGE_CONTENT_RETURN, commitUserInfo.getStaffName(), info.getGoodsName(),info.getWeight());
+        }
+
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/QingjiaProvider.java

@@ -0,0 +1,58 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.LeaveInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.ILeaveInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("qingjiaApprove")
+public class QingjiaProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private ILeaveInfoService leaveInfoService;
+
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的请假申请等待您的审核，时长{1}小时。";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        LeaveInfo info = leaveInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getLeaveDuration());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/SaleContractProvider.java

@@ -0,0 +1,66 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractGoodsInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractManagementInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractGoodsInfoService;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractManagementInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("saleContractApprove")
+public class SaleContractProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IContractManagementInfoService contractManagementInfoService;
+    @Autowired
+    private IContractGoodsInfoService contractGoodsInfoService;
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的{1}等待您的审核，合同编号:{2},{3}{4}吨";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        ContractManagementInfo info = contractManagementInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+        ContractGoodsInfo goodsInfo = contractGoodsInfoService.selectOne(new EntityWrapper<ContractGoodsInfo>()
+                .eq("contract_id",businessId));
+        if (goodsInfo == null) {
+            return null;
+        }
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getAgreementType(), info.getContractNo(),goodsInfo.getGoodsName(),info.getWeight());
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/SalesTransferInfoProvide.java

@@ -0,0 +1,40 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.SalesTransferInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.ISalesTransferInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("warehousingXszyApprove")
+public class SalesTransferInfoProvide implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+    @Autowired
+    private ISalesTransferInfoService salesTransferInfoService;
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的销售转移等待您的审核，共{1}车，{2}转至{3}。";
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+//        SalesTransferInfo info = salesTransferInfoService.selectById(businessId);
+//        if (info == null) {
+//            return null;
+//        }
+//
+//        String staffName = "XXX";
+//        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+//        if (commitUserInfo != null) {
+//            staffName = commitUserInfo.getMajorRole() != null
+//                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+//                    : commitUserInfo.getStaffName();
+//        }
+//        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getPurpose(), info.getContractNo(),info.getContractNoNew());
+            return null;
+    }
+}

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/ShouContractProvider.java

@@ -0,0 +1,67 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractGoodsInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.ContractManagementInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractGoodsInfoService;
+import com.yh.saas.plugin.yiliangyiyun.service.IContractManagementInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("shouContractApprove")
+public class ShouContractProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+
+    @Autowired
+    private IContractManagementInfoService contractManagementInfoService;
+    @Autowired
+    private IContractGoodsInfoService contractGoodsInfoService;
+    // 工作通知信息
+    static final String MESSAGE_CONTENT = "{0}发起的{1}合同等待您的审核，合同编号:{2},{3}{4}吨";
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        ContractManagementInfo info = contractManagementInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+        ContractGoodsInfo goodsInfo = contractGoodsInfoService.selectOne(new EntityWrapper<ContractGoodsInfo>()
+                .eq("contract_id",businessId));
+        if (goodsInfo == null) {
+            return null;
+        }
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getCreateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        return MessageFormat.format(MESSAGE_CONTENT, commitUserInfo.getStaffName(),info.getAgreementType(), info.getContractNo(),goodsInfo.getGoodsName(),info.getWeight());
+    }
+}
+

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/workflow/TranProessProvider.java

@@ -0,0 +1,83 @@
+package com.yh.saas.plugin.yiliangyiyun.workflow;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.winsea.svc.base.base.entity.CommonStaff;
+import com.winsea.svc.base.base.service.ICommonStaffService;
+import com.winsea.svc.base.base.util.provider.BeanWorkFlowProvider;
+import com.yh.saas.plugin.yiliangyiyun.entity.TranPriceApprove;
+import com.yh.saas.plugin.yiliangyiyun.entity.TranProcessInfo;
+import com.yh.saas.plugin.yiliangyiyun.service.ITranPriceApproveService;
+import com.yh.saas.plugin.yiliangyiyun.service.ITranProcessInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.MessageFormat;
+
+@Component("yunjiaTranApprove")
+public class TranProessProvider implements BeanWorkFlowProvider {
+    @Autowired
+    private ICommonStaffService staffService;
+    @Autowired
+    private ITranProcessInfoService tranProcessInfoService;
+    @Autowired
+    private ITranPriceApproveService tranPriceApproveService;
+
+    // 工作通知信息
+    static final String MESSAGE_CAR_CONTENT = "{0}发起的汽运单价等待您的审核，单价金额{1}元/车。";
+    static final String MESSAGE_KG_CONTENT = "{0}发起的汽运单价等待您的审核，单价金额{1}元/吨。";
+    static final String MESSAGE_SHIP_CONTENT = "{0}发起的船运总价等待您的审核，总价金额{1}元。";
+    static final String MESSAGE_FIRE_CONTENT = "{0}发起的船运总价等待您的审核，总价金额{1}元。";
+
+
+    @Override
+    public String getDeptId(String businessId) {
+        return null;
+    }
+
+    @Override
+    public String getNoticeCopywriting() {
+        return null;
+    }
+
+    @Override
+    public String getVesselId(String businessId) {
+        return null;
+    }
+
+    /**
+     * 获取文案(审核中)
+     */
+    @Override
+    public String getNotificeTask(String businessId) {
+        TranProcessInfo info = tranProcessInfoService.selectById(businessId);
+        if (info == null) {
+            return null;
+        }
+        String staffName = "XXX";
+        CommonStaff commitUserInfo = staffService.getInfo(info.getUpdateUserId());
+        if (commitUserInfo != null) {
+            staffName = commitUserInfo.getMajorRole() != null
+                    ? commitUserInfo.getMajorRole().getRoleName() + " " + commitUserInfo.getStaffName()
+                    : commitUserInfo.getStaffName();
+        }
+        //汽运
+        if("1".equals(info.getTranTypeKey())){
+            //按吨
+            if("1".equals(info.getBillingMethod())){
+                return MessageFormat.format(MESSAGE_KG_CONTENT, commitUserInfo.getStaffName(),info.getTranPriceIng());
+            }
+            //按车
+            else {
+                return MessageFormat.format(MESSAGE_CAR_CONTENT, commitUserInfo.getStaffName(),info.getTranPriceIngCar());
+            }
+        }
+        //火运
+        else if("2".equals(info.getTranTypeKey())){
+            return MessageFormat.format(MESSAGE_FIRE_CONTENT, commitUserInfo.getStaffName(),info.getTranPriceIng());
+        }
+        //船运
+        else{
+            return MessageFormat.format(MESSAGE_SHIP_CONTENT, commitUserInfo.getStaffName(),info.getTranPriceIng());
+        }
+    }
+}