package com.dy.pipIrrSell.clientTemp;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.dy.common.aop.SsoAop;
|
import com.dy.common.webUtil.BaseResponse;
|
import com.dy.common.webUtil.BaseResponseUtils;
|
import com.dy.pipIrrGlobal.pojoSe.SeClient;
|
import com.dy.pipIrrGlobal.pojoSe.SeClientTemp;
|
import com.dy.pipIrrSell.client.ClientSv;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author ZhuBaoMin
|
* @date 2024-09-26 15:03
|
* @LastEditTime 2024-09-26 15:03
|
* @Description
|
*/
|
|
@Slf4j
|
@RestController
|
@RequestMapping(path = "client_temp")
|
@RequiredArgsConstructor
|
public class ClientTempCtrl {
|
private final ClientTempSv clientTempSv;
|
private final ClientSv clientSv;
|
|
/**
|
* 导入农户
|
* @param townName
|
* @return
|
*/
|
@PostMapping(path = "import")
|
@Transactional(rollbackFor = Exception.class)
|
@SsoAop()
|
public BaseResponse<Boolean> importClient(String townName){
|
List<SeClientTemp> list_client = clientTempSv.getClientsByTownName(townName);
|
if(list_client != null && list_client.size() > 0) {
|
JSONArray array_Clients = (JSONArray) JSON.toJSON(list_client);
|
for (int i = 0; i < array_Clients.size(); i++) {
|
JSONObject job_client = array_Clients.getJSONObject(i);
|
String town = job_client.getString("town");
|
String village = job_client.getString("village");
|
String name = job_client.getString("name");
|
String idCard = job_client.getString("idcard");
|
String phone = job_client.getString("phone");
|
if(phone != null && phone.length() > 11) {
|
phone = phone.substring(0,11);
|
}
|
String address = job_client.getString("address");
|
|
if(town.trim().equals("元马镇6号")) {
|
SeClient client = new SeClient();
|
//client.setCountyid(28L);
|
//client.setTownid(101L);
|
//client.setVillageid(6L);
|
client.setCountyid(2024090516595200202L);
|
client.setTownid(2024090517240900002L);
|
client.setVillageid(2024090517284400002L);
|
client.setBlockid(2024090517155600002L);
|
client.setDivideid(2024090517323800007L);
|
client.setName(name);
|
client.setClientnum("28101006" + String.format("%04d", i+1));
|
client.setDistrictnum(532328101006L);
|
client.setDistricttitle("元谋县元马镇清和社区居民委员会");
|
client.setPhone(phone);
|
client.setIdcard(idCard);
|
client.setTypeid(2024090516595201402L);
|
client.setAddress(address);
|
client.setOperator (2024090516595200302L);
|
client.setOperatedt(new Date());
|
client.setDisabled((byte)0);
|
client.setDeleted((byte)0);
|
|
Integer rec = clientSv.addClient(client);
|
} else if(town.trim().equals("老城乡2号")) {
|
SeClient client = new SeClient();
|
//client.setCountyid(28L);
|
//client.setTownid(202L);
|
//client.setVillageid(204L);
|
client.setCountyid(2024090516595200202L);
|
client.setTownid(2024090517252600002L);
|
client.setVillageid(2024090517294000002L);
|
client.setBlockid(2024090517155600002L);
|
client.setDivideid(2024090517355700007L);
|
client.setName(name);
|
client.setClientnum("28202204" + String.format("%04d", i));
|
client.setDistrictnum(532328202204L);
|
client.setDistricttitle("元谋县老城乡挨小村民委员会");
|
client.setPhone(phone);
|
client.setIdcard(idCard);
|
client.setTypeid(2024090516595201402L);
|
client.setAddress(address);
|
client.setOperator (2024090516595200302L);
|
client.setOperatedt(new Date());
|
client.setDisabled((byte)0);
|
client.setDeleted((byte)0);
|
|
Integer rec = clientSv.addClient(client);
|
}
|
|
System.out.println("-----------------------------: " + i);
|
}
|
|
}
|
return BaseResponseUtils.buildSuccess();
|
}
|
}
|
