/**
|
* wangweipeng 2021/07/12 11:25 SWAG-C4P8CM
|
* 每天更新 opd计划表的 if_Newest_HaveOpportunity__c 字段值
|
*/
|
global class OPDIfNewestHaveOpportunityBatch implements Database.Batchable<sObject> {
|
public String query;
|
private String errStr;
|
private BatchIF_Log__c iflog;
|
private final List<Id> TEST_ID = null;
|
|
global OPDIfNewestHaveOpportunityBatch() {
|
query = '';
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'PushNotification';
|
iflog.Is_Error__c = 0;
|
iflog.Log__c = 'OPDIfNewestHaveOpportunityBatch start1\n';
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
}
|
global OPDIfNewestHaveOpportunityBatch(List<Id> testId) {
|
query = '';
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'PushNotification';
|
iflog.Is_Error__c = 0;
|
iflog.Log__c = 'OPDIfNewestHaveOpportunityBatch start1\n';
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
TEST_ID = testId;
|
}
|
global Database.QueryLocator start(Database.BatchableContext bc) {
|
Datetime startDate = Date.today();
|
Datetime endDate = Date.today().addDays(1);
|
Date dateToday = Date.today();
|
Date yesterday = dateToday.addDays(-1);
|
Integer year = yesterday.year();
|
Integer month = yesterday.month();
|
Integer buffer = Integer.valueOf(System.Label.update_If_Newest_HaveOpportunity);
|
if (month < 4) {
|
year -= 1;
|
}
|
String ocmYear = year + '年度';
|
|
query = 'SELECT id,Name,Status__c,OPD_Customers_Target__c,OPD_Customers_Target_Last__c,NoNSupplementaryApplication__c,ModelLending__c,PlanProdDetail__c,if_Newest_HaveOpportunity__c'
|
+ ' from OPDPlan__c'
|
+ ' WHERE PlanProdDetail__c != null' //计划出借备品信息
|
+ ' AND OPD_Customers_Target__c != null '; //当期的客户-目标客户
|
if(buffer == 1){//更新一下2021/7/28 到 2020年11月1号的数据
|
query += ' AND Status__c != null '
|
+ ' AND OPD_Customers_Target__r.OCM_Year__c in (\'2020年度\',\'2021年度\') '
|
+ ' AND OPD_Customers_Target__r.CreatedDate >= 2020-11-01T00:01:01.000+0000 and OPD_Customers_Target__r.CreatedDate <= 2021-07-28T23:59:59.000+0000 ';
|
}else{
|
query+= ' AND Status__c in (\'计划中\',\'取消\',\'完毕未报告\',\'完毕\')'
|
+ ' AND OPD_Customers_Target__r.OCM_Year__c = :ocmYear '
|
+ ' AND OPD_Customers_Target__r.LastModifiedDate >= :startDate and OPD_Customers_Target__r.LastModifiedDate <= :endDate ';
|
}
|
if (TEST_ID <> null) {
|
query += ' and Id IN: TEST_ID';
|
}
|
iflog.Log__c += query+'\n';
|
update iflog;
|
return Database.getQueryLocator(query);
|
}
|
|
global void execute(Database.BatchableContext BC, list<OPDPlan__c> scope) {
|
if(scope != null && scope.size() > 0){
|
List<OPDPlan__c> dataOpdList = scope;
|
Integer FIELDMAX = 144;
|
//去mapping表中找到名字为targetKeyProduct的一条数据
|
SS_Batch_Column_Mapping__c mpdMapping = SS_Batch_Column_Mapping__c.getValues('targetKeyProduct');
|
//对应目标客户中的一系列 询价数 用来判断“是否有询价”
|
List<String> columnOppCnt = new List<String>();
|
Map<String, String> tempImportantOppCnt = new Map<String, String>();
|
//获取到 客户-目标客户 表的询价的字段名
|
for (Integer i = 129; i <= FIELDMAX; i++) {
|
String lpadI = ('00' + i).right(3);
|
String fromColumn = 'From_Column_' + lpadI + '__c';//假设执行此时 值是 From_Column_115__c
|
String apiStr = String.valueOf(mpdMapping.get(fromColumn)); //取字段fromColumn上存储的数据为Rental_Cnt_USG400__c
|
if (String.isBlank(apiStr) == false) {
|
String ssColumn = 'SS_Column_' + lpadI + '__c';//SS_Column_115__c
|
String ssApiStr = String.valueOf(mpdMapping.get(ssColumn));//取得是 字段SS_Column_115__c 上的存储的数据 USG-400
|
if (i >= 129 && i < 144) { //询价数 1，0
|
columnOppCnt.add(apiStr);
|
tempImportantOppCnt.put(apiStr, ssApiStr);
|
}
|
}
|
}
|
Map<id, String> OpdTargetAcc = new Map<id, String>();
|
for(Integer i = 0;i < dataOpdList.size() ;i++){
|
if(dataOpdList[i].PlanProdDetail__c != null){
|
OpdTargetAcc.put(dataOpdList[i].id,dataOpdList[i].OPD_Customers_Target__c);
|
}
|
}
|
Map<id, Account_Number_of_target__c> acctarList = new Map<id, Account_Number_of_target__c>([select id, OPD_CV290__c, OPD_EUME2__c, OPD_290Miro__c, OPD_GFUCT260__c, OPD_OTVS300S400__c, OPD_CV170__c, OPD_190Main__c, OPD_ENG__c, OPD_TB__c,
|
Sales_target_CV290__c,
|
Sales_target_290Miro__c,
|
Sales_target_EUME2__c,
|
Sales_target_GFUCT260__c,
|
Sales_target_OTVS300S400__c,
|
Sales_target_CV170__c,
|
Sales_target_190Main__c,
|
Sales_target_ENG__c,
|
Sales_target_TB__c,
|
Opp_cnt_290MiroBF__c,
|
Opp_cnt_290MiroGI__c,
|
Opp_cnt_290MiroGI_CF__c,
|
Opp_cnt_290MiroGI_Plus__c,
|
Opp_cnt_CV170__c,
|
Opp_cnt_CV190__c,
|
Opp_cnt_CV290__c,
|
Opp_cnt_ESG400__c,
|
Opp_cnt_EUME2__c,
|
Opp_cnt_GFUCT260__c,
|
Opp_cnt_OTVS190__c,
|
Opp_cnt_OTVS300__c,
|
Opp_cnt_OTVS400__c,
|
Opp_cnt_TB__c,
|
Opp_cnt_USG400__c,
|
Opp_cnt_190Main__c,
|
Asset_Cnt_290MiroBF__c,
|
Asset_Cnt_290MiroGI__c,
|
Asset_Cnt_290MiroGI_CF__c,
|
Asset_Cnt_290MiroGI_Plus__c,
|
Asset_Cnt_CV170__c,
|
Asset_Cnt_CV190__c,
|
Asset_Cnt_CV290__c,
|
Asset_Cnt_ESG400__c,
|
Asset_Cnt_EUME2__c,
|
Asset_Cnt_GFUCT260__c,
|
Asset_Cnt_OTVS190__c,
|
Asset_Cnt_OTVS300__c,
|
Asset_Cnt_OTVS400__c,
|
Asset_Cnt_TB__c,
|
Asset_Cnt_USG400__c,
|
Asset_Cnt_190Main__c,
|
OPD_amount_290MiroBF__c,
|
OPD_amount_290MiroGI__c,
|
OPD_amount_290MiroGI_CF__c,
|
OPD_amount_290MiroGI_Plus__c,
|
OPD_amount_CV170__c,
|
OPD_amount_CV190__c,
|
OPD_amount_CV290__c,
|
OPD_amount_ESG400__c,
|
OPD_amount_EUME2__c,
|
OPD_amount_GFUCT260__c,
|
OPD_amount_OTVS190__c,
|
OPD_amount_OTVS300__c,
|
OPD_amount_OTVS400__c,
|
OPD_amount_TB__c,
|
OPD_amount_USG400__c,
|
OPD_amount_190Main__c,
|
Rental_Cnt_290MiroBF__c,
|
Rental_Cnt_290MiroGI__c,
|
Rental_Cnt_290MiroGI_CF__c,
|
Rental_Cnt_290MiroGI_Plus__c,
|
Rental_Cnt_CV170__c,
|
Rental_Cnt_CV190__c,
|
Rental_Cnt_CV290__c,
|
Rental_Cnt_ESG400__c,
|
Rental_Cnt_EUME2__c,
|
Rental_Cnt_GFUCT260__c,
|
Rental_Cnt_OTVS190__c,
|
Rental_Cnt_OTVS300__c,
|
Rental_Cnt_OTVS400__c,
|
Rental_Cnt_TB__c,
|
Rental_Cnt_USG400__c,
|
Rental_Cnt_190Main__c
|
from Account_Number_of_target__c
|
where id in :OpdTargetAcc.values()]);//查询目标客户 本财年的
|
|
//修改对象
|
List <OPDPlan__c> ListUpdOpdplan = new List<OPDPlan__c>();
|
for(Integer i = 0;i < dataOpdList.size() ;i++){
|
OPDPlan__c opdplan = new OPDPlan__c();
|
opdplan.id = dataOpdList[i].id;
|
Integer ifNewestHaveOpportunity;
|
//计划出借备品信息 不为空
|
if(dataOpdList[i].PlanProdDetail__c != null){
|
if (acctarList.containskey(dataOpdList[i].OPD_Customers_Target__c)) {
|
//不能去掉所有空格，因为有一个特殊得（OTV-S400 4K主机）.replaceAll(' ', ''); //GI-290镜子*3; GI-290镜子CF*1; OTV-S400 4K主机*3; OTV-S190*2; TB*8
|
String ppd = dataOpdList[i].PlanProdDetail__c;
|
//(GI-290镜子*3, GI-290镜子CF*1, OTV-S400 4K主机*3, OTV-S190*2, TB*8)
|
String[] strs = ppd.split(';');
|
//控制是否跳出循环
|
boolean flag = false;
|
for (Integer j = 0; j < strs.size(); j++) {
|
String strss = strs[j].split('\\*')[0].trim();
|
if (columnOppCnt != null) {
|
for (Integer o = 0; o < columnOppCnt.size(); o++) { //是否有询价数
|
String titleAccout2 = tempImportantOppCnt.get(columnOppCnt[o]);
|
if (strss.indexOf(titleAccout2) != -1) {
|
if (acctarList.get(dataOpdList[i].OPD_Customers_Target__c).get(columnOppCnt[o]) != null && acctarList.get(dataOpdList[i].OPD_Customers_Target__c).get(columnOppCnt[o]) != 0) {
|
ifNewestHaveOpportunity = 1;
|
flag = true;
|
break;
|
}
|
}
|
}
|
}
|
if(flag){
|
break;
|
}
|
}
|
}
|
}
|
opdplan.if_Newest_HaveOpportunity__c = ifNewestHaveOpportunity;
|
ListUpdOpdplan.add(opdplan);
|
}
|
|
Savepoint sp = Database.setSavepoint();
|
try{
|
update ListUpdOpdplan;
|
}catch(exception e){
|
errStr = e.getMessage()+'\n';
|
errStr += e.getLineNumber()+'\n';
|
Database.rollback(sp);
|
}
|
}
|
}
|
|
global void finish(Database.BatchableContext BC) {
|
String tmp = '';
|
if (String.isNotBlank(errStr)) {
|
tmp = errStr;
|
}
|
iflog.Log__c += 'OPDIfNewestHaveOpportunityBatch finish()\n';
|
iflog.Log__c += '\nOPDIfNewestHaveOpportunityBatch end';
|
|
tmp += iflog.ErrorLog__c;
|
if (tmp.length() > 60000) {
|
tmp = tmp.substring(0, 60000);
|
tmp += ' ...have more lines...';
|
iflog.ErrorLog__c = tmp;
|
}
|
String tmp2 = iflog.Log__c;
|
if (tmp2.length() > 60000) {
|
tmp2 = tmp2.substring(0, 60000);
|
tmp2 += ' ...have more lines...';
|
iflog.Log__c = tmp2;
|
}
|
if (System.Label.Log_IO_Flag == 'Keep') {
|
update iflog;
|
} else if (System.Label.Log_IO_Flag == 'Auto') {
|
if (iflog.Is_Error__c > 0) {
|
update iflog;
|
}
|
}
|
}
|
}
|
